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
OK, I've finally tracked down the problem as to why signaller is not reconnecting to a websocket (or other endpoint) when I thought it should be, and like all things it's quite obvious once you know.
Basically, the outbound message queue is a pull-pushable instance (created here and only one is created for the lifetime of the signaller. This is a problem, however, as when the transport sink stream ends, the pushable source goes into an ended state and will henceforce report itself as ended (which in turn ends the sink, noticeable in most cases by the websocket closing).
While one option would be creating a new pushable instance to use a source when invoking the reconnect code, but would require copying any existing buffered messages stored in the current queue across to the new queue. Another would be to implement a function that allows the resetting the ended state of the pull-pushable source.
The text was updated successfully, but these errors were encountered:
OK, I've finally tracked down the problem as to why signaller is not reconnecting to a websocket (or other endpoint) when I thought it should be, and like all things it's quite obvious once you know.
Basically, the outbound message queue is a
pull-pushable
instance (created here and only one is created for the lifetime of the signaller. This is a problem, however, as when the transport sink stream ends, the pushable source goes into an ended state and will henceforce report itself as ended (which in turn ends the sink, noticeable in most cases by the websocket closing).While one option would be creating a new pushable instance to use a source when invoking the reconnect code, but would require copying any existing buffered messages stored in the current queue across to the new queue. Another would be to implement a function that allows the resetting the
ended
state of the pull-pushable source.The text was updated successfully, but these errors were encountered: