-
Notifications
You must be signed in to change notification settings - Fork 21
Single active consumer implementation #248
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
e544dc2
to
c7189a3
Compare
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## main #248 +/- ##
==========================================
+ Coverage 89.33% 89.49% +0.16%
==========================================
Files 78 80 +2
Lines 6748 7003 +255
==========================================
+ Hits 6028 6267 +239
- Misses 720 736 +16 ☔ View full report in Codecov by Sentry. 🚨 Try these New Features:
|
8b8266f
to
0aba4b1
Compare
0aba4b1
to
fc9578d
Compare
b2b8951
to
d5b8869
Compare
d5b8869
to
ff83eb7
Compare
@Gsantomaggio @wolf4ood There can be still some improvements to do but we can start to review this one! |
345f435
to
7904411
Compare
examples/single_active_consumer/single_active_consumer_super_stream.rs
Outdated
Show resolved
Hide resolved
examples/single_active_consumer/single_active_consumer_super_stream.rs
Outdated
Show resolved
Hide resolved
a3f7a92
to
116193f
Compare
@Gsantomaggio I think the suggestions have been addressed, back to you for review! |
Discussing with @Gsantomaggio we can merge this one and improve the example in another PR |
This closes #130
This PR implements the single active consumer functionality:
An example can be found in: examples/single_active_consumer/single_active_consumer_super_stream.rs