Struct TransportPeer 

pub struct TransportPeer { /* private fields */ }

Forwards envelopes through a ClientTransport.

Implementations

impl TransportPeer

pub fn new(transport: Arc<dyn ClientTransport>) -> Self

A peer sending through transport.

Trait Implementations

impl BridgePeer for TransportPeer

fn send( &self, envelope: Map<String, Value>, ) -> SendFuture<'_, Result<Map<String, Value>, BridgeError>>

Delivers one request and yields the answer, under the caller’s id.

Errors

BridgeError::Unreachable when the request could not be delivered or its answer could not be read. A refusal from the peer is an Ok envelope with an error member.

fn notify( &self, envelope: Map<String, Value>, ) -> SendFuture<'_, Result<(), BridgeError>>

Delivers a notification.

Errors

BridgeError::Unreachable when it could not be delivered.

fn close(&self) -> SendFuture<'_, Result<(), BridgeError>>

There is no session to end.

fn take_pending(&self) -> Vec<Map<String, Value>>

Frames the peer received that are the answer to nothing the bridge asked.

fn wait_pending(&self) -> SendFuture<'static, ()>

Resolves once the peer may have something for take_pending.

fn listen(&self) -> SendFuture<'_, Result<(), BridgeError>>

Starts delivering frames the peer pushes on its own.

impl Clone for TransportPeer

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TransportPeer

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

Formats the value using the given formatter.