Struct WebSocketRpcTransport 

pub struct WebSocketRpcTransport { /* private fields */ }

RpcTransport implementation of a Dart side WebSocket.

Implementations

impl WebSocketRpcTransport

pub fn new() -> Self

Creates a new WebSocketRpcTransport which can be connected to the server with the RpcTransport::connect() method call.

Trait Implementations

impl Clone for WebSocketRpcTransport

fn clone(&self) -> WebSocketRpcTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WebSocketRpcTransport

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

Formats the value using the given formatter.

impl Default for WebSocketRpcTransport

fn default() -> Self

Returns the “default value” for a type.

impl Drop for WebSocketRpcTransport

fn drop(&mut self)

Executes the destructor for this type.

impl RpcTransport for WebSocketRpcTransport

fn connect<'life0, 'async_trait>( &'life0 self, url: ApiUrl, ) -> Pin<Box<dyn Future<Output = Result<(), Traced<TransportError>>> + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initiates a new WebSocket connection to the provided url.

fn on_message(&self) -> LocalBoxStream<'static, ServerMsg>

Returns LocalBoxStream of all messages received by this transport.

fn set_close_reason(&self, reason: ClientDisconnect)

Sets reason, that will be sent to remote server when this transport will be dropped.

fn send(&self, msg: &ClientMsg) -> Result<(), Traced<TransportError>>

Sends given ClientMsg to a server.

fn on_state_change(&self) -> LocalBoxStream<'static, TransportState>

Subscribes to a RpcTransport’s TransportState changes.