Skip to content

Navigation Menu

Appearance settings

Explore
By company size
By use case
By industry
View all solutions
Topics
- AI
- DevOps
- Security
- Software Development
- View all
Explore
- GitHub Sponsors
  Fund open source developers
- The ReadME Project
  GitHub community articles
Repositories
- Enterprise platform
  AI-powered developer platform
Available add-ons
Pricing

Search code, repositories, users, issues, pull requests...

Search

Clear

Search syntax tips

Provide feedback

We read every piece of feedback, and take your input very seriously.

Include my email address so I can be contacted

Saved searches

Use saved searches to filter your results more quickly

Name

Query

To see all available qualifiers, see our documentation.

Appearance settings

You signed in with another tab or window. Reload to refresh your session. You signed out in another tab or window. Reload to refresh your session. You switched accounts on another tab or window. Reload to refresh your session.

Dismiss alert

rabbitmq / rabbitmq-stream-rust-client Public

Notifications You must be signed in to change notification settings
Fork 21
Star 193

Code
Issues 14
Pull requests 4
Discussions
Actions
Projects
Security
Insights

Additional navigation options

Code
Issues
Pull requests
Discussions
Actions
Projects
Security
Insights

Implement super_stream #232

Merged

DanielePalaia merged 28 commits intomainrabbitmq/rabbitmq-stream-rust-client:mainfrom

implement_super_streamrabbitmq/rabbitmq-stream-rust-client:implement_super_streamCopy head branch name to clipboard

Oct 30, 2024

Conversation Commits28 (28)Checks Files changed

Merged

Implement super_stream #232
DanielePalaia merged 28 commits intomainfrom
implement_super_stream

Commits

Commits on Oct 30, 2024

WIP: implementing create and delete superstream commands
DanielePalaia
committed
implementing route and partition commands
DanielePalaia
committed
refactoring tests
DanielePalaia
committed
super_stream implementation
DanielePalaia
committed
superstream producer implementation
DanielePalaia
committed
super_stream_producer first basic version
DanielePalaia
committed
finalizing superstream_producer and tests
DanielePalaia
committed
better implementation/refactoring
DanielePalaia
committed
making Messages as references to allow borrowing
DanielePalaia
committed
implementing super_stream consumer
DanielePalaia
committed
some refactoring
DanielePalaia
committed
fixing super_stream_consumer test
DanielePalaia
committed
fix clippy issue
DanielePalaia
committed
adding, stream method to consumer delivery struct and adding examples
DanielePalaia
committed
fixing offset in SuperstreamConsumer
DanielePalaia
committed
super_stream_consumer new approach
DanielePalaia
committed
implementing close()
DanielePalaia
committed
implement filtering on super_stream
DanielePalaia
committed
adding super_stream_filtering tests
DanielePalaia
committed
error handling improvement in super_stream send
DanielePalaia
committed
improve super_stream send example
DanielePalaia
committed
add information to the example

Gsantomaggio
authored and
DanielePalaia
committed
small performance improvement in HashRoutingMurmurStrategy
DanielePalaia
committed
add information to the example

Gsantomaggio
authored and
DanielePalaia
committed
close super stream consumer

Gsantomaggio
authored and
DanielePalaia
committed
fix bug in super_stream_producer client created twice
DanielePalaia
committed
merging
DanielePalaia
committed
updating README.md
DanielePalaia
committed

Footer

© 2025 GitHub, Inc.

Footer navigation

Terms
Privacy
Security
Status
Docs
Contact

You can’t perform that action at this time.