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
The underyling Stream of the WebSocketChannel is a single-subscription stream. Meaning it can only be listened to once. By using stream.last twice, you try to listen to it twice, which isn't allowed. Here is an excerpt from the documentation:
A single-subscription stream allows only a single listener during the whole lifetime of the stream. It doesn't start generating events until it has a listener, and it stops sending events when the listener is unsubscribed, even if the source of events could still provide more. The stream created by an async* function is a single-subscription stream, but each call to the function creates a new such stream.
Listening twice on a single-subscription stream is not allowed, even after the first subscription has been canceled.
Hi,
I try to have a sequential read of every message, because I have a protocol to follow, it is in 3 steps:
And so I wish to:
Here is what I tried:
But I got an exception at the last 'channel.stream.last' : Unhandled Exception: Bad state: Stream has already been listened to
Any idea why, and how to manage this ?
Thanks
The text was updated successfully, but these errors were encountered: