Struct PollingClient

pub struct PollingClient {
    pub url: String,
    pub event_client: EventClient,
    pub status: Rc<RefCell<ConnectionStatus>>,
    /* private fields */
}

Fields

url: String

The URL this client is connected to

event_client: EventClient

The core EventClient this client is using

status: Rc<RefCell<ConnectionStatus>>

The current connection status

Implementations

impl PollingClient

pub fn new(url: &str) -> Result<Self, WebSocketError>

Create a new PollingClient and connect to a WebSocket URL

Note: An Ok() from this function does not mean the connection has succeeded.

PollingClient::new("wss://ws.ifelse.io")?;

pub fn receive(&mut self) -> Vec<Message>

Get all new WebSocket messages that were received since this function was last called

println!("New messages: {:#?}", client.receive());

pub fn status(&self) -> ConnectionStatus

Get the client’s current connection status

println!("Current status: {:#?}", client.status());

pub fn send_string(&self, message: &str) -> Result<(), JsValue>

Send a text message to the server

client.send_string("Hello server!")?;

pub fn send_binary(&self, message: Vec<u8>) -> Result<(), JsValue>

Send a binary message to the server

client.send_binary(vec![0x2, 0xF])?;

pub fn close(&self) -> Result<(), JsValue>

Close the connection

client.close()?;

pub fn close_with(&self, code: u16, reason: Option<&str>) -> Result<(), JsValue>

Close the connection with a custom close code and, optionally, a reason string

The reason string must be at most 123 bytes long.

client.close_with(1001, Some("going away"))?;