Struct PubSubConnection

pub struct PubSubConnection<Handler: PubSubRpcHandler, Connection> {
    handler: Handler,
    context: PubSubContext<Handler>,
    connection: Connection,
    processing: Vec<Pin<Box<dyn Future<Output = Response> + Send>>>,
    pending: VecDeque<String>,
}

Represents a connection to a client via websocket

Contains the state for the entire connection

Fields

handler: Handler

the handler for the websocket connection

context: PubSubContext<Handler>

contains all the subscription related context

connection: Connection

The established connection

processing: Vec<Pin<Box<dyn Future<Output = Response> + Send>>>

currently in progress requests

pending: VecDeque<String>

pending messages to send

Implementations

impl<Handler: PubSubRpcHandler, Connection> PubSubConnection<Handler, Connection>

pub fn new(connection: Connection, handler: Handler) -> Self

fn compat_helper(&self) -> ContextAwareHandler<Handler>

Returns a compatibility RpcHandler

fn process_request(&mut self, req: Result<Request>)

Trait Implementations

impl<Handler, Connection> Future for PubSubConnection<Handler, Connection>

where Handler: PubSubRpcHandler, Connection: Sink<String> + Stream<Item = Result<Option<Request>, RequestError>> + Unpin, <Connection as Sink<String>>::Error: Debug,

type Output = ()

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.