Struct medea_jason::rpc::RpcClient

pub struct RpcClient(_);

Methods

impl RpcClient

pub fn new(token: String, ping_interval: i32) -> Self

pub fn init(&mut self) -> impl Future<Item = (), Error = WasmErr>

Creates new WebSocket connection to remote media server. Starts Heartbeat if connection succeeds and binds handlers on receiving messages from server and closing socket.

pub fn subscribe(&self) -> impl Stream<Item = Event, Error = ()>

Returns Stream of all Events received by this RpcClient.

pub fn unsub(&self)

Unsubscribe from this RpcClient. Drops all subscriptions atm.

pub fn send_command(&self, command: Command)

Sends Command to Medea.

Trait Implementations

impl Drop for RpcClient

fn drop(&mut self)

Drops related connection and its [Heartbeat].