Struct Session

pub(crate) struct Session {
    pub(crate) adapter_id: AdapterId,
    pub(crate) config: OwpConfig,
    pub(crate) schema: Option<Arc<Schema>>,
    pub(crate) conn_id: u64,
    pub(crate) ws: WebSocketStream<MaybeTlsStream<TcpStream>>,
    pub(crate) engine: Arc<Engine>,
    pub(crate) shutdown: CancellationToken,
}

One accepted WebSocket and the engine handle it publishes through.

conn_id is unique per accept on this adapter. Engine subscription ids are {conn_id}:{sid} so two connections can reuse a client sid.

Fields

adapter_id: AdapterId

config: OwpConfig

schema: Option<Arc<Schema>>

conn_id: u64

ws: WebSocketStream<MaybeTlsStream<TcpStream>>

engine: Arc<Engine>

shutdown: CancellationToken