Struct jsonrpc_pubsub::Session

pub struct Session { /* fields omitted */ }

RPC client session Keeps track of active subscriptions and unsubscribes from them upon dropping.

Implementations

impl Session

pub fn new(sender: UnboundedSender<String>) -> Self

Creates new session given transport raw send capabilities. Session should be created as part of metadata, sender should be returned by transport.

pub fn sender(&self) -> UnboundedSender<String>

Returns transport write stream

pub fn on_drop<F: FnOnce() + Send + 'static>(&self, on_drop: F)

Adds a function to call when session is dropped.

Trait Implementations

impl Debug for Session

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Session

fn drop(&mut self)

Executes the destructor for this type.