Struct TransportConnectionWrapper 

pub struct TransportConnectionWrapper { /* private fields */ }

A connection around another one that keeps the events raised before a handler is subscribed, and that queues the messages to send so that any number of threads may send at once.

Implementations

impl TransportConnectionWrapper

pub fn new( conn: Arc<dyn IFerroRemoteTransportConnection>, ) -> Arc<TransportConnectionWrapper>

Trait Implementations

impl Drop for TransportConnectionWrapper

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl IFerroRemoteTransportConnection for TransportConnectionWrapper

fn send(&self, data: Message) -> Task

Queues the message and returns; the task completes when the worker has sent it. Messages are sent in the order they were queued.

fn dispose(&self)

IDisposable.Dispose: closes the connection. No exception event follows from the closing itself.

fn on_message(&self, handler: MessageHandler) -> HandlerToken

OnMessage += handler.

fn remove_on_message(&self, token: HandlerToken)

OnMessage -= handler.

fn on_exception(&self, handler: ExceptionHandler) -> HandlerToken

OnException += handler.

fn remove_on_exception(&self, token: HandlerToken)

OnException -= handler.

fn start(&self)