pub(crate) async fn run(session: Session) -> Result<(), AdapterError>Expand description
Runs session until shutdown, close, or a fatal protocol error.
On the way out every live SUB is aborted and unsubscribed. This does
not call Engine::drop_adapter: other connections on the same
adapter must keep their subscriptions.
ยงErrors
Does not fail. Handshake already succeeded; I/O errors end the loop
as Ok.