-
Notifications
You must be signed in to change notification settings - Fork 6
Open
Description
Currently the join operation only checks whether it can join a message once per buffer update. However there are situations where a buffer may suddenly receive multiple messages at once, and the join may be able to generate multiple messages from that single update.
We should ensure that we do not attempt to drain the buffers if all buffers are fetch-by-clone. In that case we should continue to limit the join operation to one message per update.