-
Notifications
You must be signed in to change notification settings - Fork 77
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
Set topicID on outbound IHAVE and ignore inbound IHAVE for unknown topic #365
Set topicID on outbound IHAVE and ignore inbound IHAVE for unknown topic #365
Conversation
f718183
to
ec91b77
Compare
I think we would need to group |
a7edabd
to
a3e5212
Compare
Isn't that what the val shuffledMessageIds = ids.shuffled(random).take(params.maxIHaveLength) I suppose we could be more efficient when flushing the queue. Is it worth to make this improvement a separate PR? |
Please check here: StefanBratanov#1 |
Thanks. I agree with the change. I have missed that part. Thanks. |
Added another minor improvement |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
fixes #361