pub trait SubscriptionConnection<S>: Stream<Item = ExecutionOutput<S>> { }Expand description
Single subscription connection.
This trait implementation might:
- hold schema + context
- process subscribe, unsubscribe
- unregister from coordinator upon close/shutdown
- connection-local + global de-duplication, talk to coordinator
- concurrency limits
- machinery with coordinator to allow reconnection
It can be treated as futures::Stream yielding GraphQLResponses in
server integration crates.