We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
(I apologize for this question as I am a beginner to scala)
Is there an example anywhere on how to use sendAsync?
sendAsync
I am trying to do the following: if sCol is a collection on strings Then I would like to do sCol.map(producer.sendAsync(_)) wait until all complete
sCol
sCol.map(producer.sendAsync(_))
wait until all complete
The text was updated successfully, but these errors were encountered:
Or does the default send use batching without waiting?
send
Sorry, something went wrong.
If I just do sCol.map(producer.send(_)), then it is terribly slow so I do not think the messages are being batched
sCol.map(producer.send(_))
Your last example will send one at a time. You can sendAsync then collect all the futures using .sequence and then await on that.
No branches or pull requests
(I apologize for this question as I am a beginner to scala)
Is there an example anywhere on how to use
sendAsync
?I am trying to do the following:
if
sCol
is a collection on stringsThen I would like to do
sCol.map(producer.sendAsync(_))
wait until all complete
The text was updated successfully, but these errors were encountered: