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
Ref #114, currently the stream uses send from SinkExt in multiple places, which completes when the Sink has fully processed the item. Instead, it should be using the Sink API like this, buffering requests when the Sink is not ready:
ifpoll_ready().is_ready(){start_send(msg)}else{// need to buffer until sink ready.}
The text was updated successfully, but these errors were encountered:
Ref #114, currently the stream uses
send
fromSinkExt
in multiple places, which completes when theSink
has fully processed the item. Instead, it should be using theSink
API like this, buffering requests when theSink
is not ready:The text was updated successfully, but these errors were encountered: