Struct splinter::transport::ws::WsTransport

pub struct WsTransport {}

A WebSocket-based Transport.

Supports endpoints of the format ws://ip_or_host:port.

Examples

To connect to the a remote endpoint, send a message, and receive a reply message:

use splinter::transport::Transport as _;
use splinter::transport::ws::WsTransport;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut transport = WsTransport::default();

    // Connect to a remote endpoint starting wtih `ws://`.
    let mut connection = transport.connect("ws://127.0.0.1:5555")?;

    // Send some bytes
    connection.send(b"hello world")?;

    // Receive a response
    let msg = connection.recv()?;

    // Disconnect
    connection.disconnect()?;

    Ok(())
}

To accept a connection, receive, and send a reply:

use splinter::transport::Transport as _;
use splinter::transport::ws::WsTransport;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut transport = WsTransport::default();

    // Create a listener, which will bind to the port
    let mut listener = transport.listen("ws://127.0.0.1:5555")?;

    // When the other side connects, accept will return a `Connection`
    let mut connection = listener.accept()?;

    // Receive a message
    let msg = connection.recv()?;

    // Send a response
    connection.send(b"hello world")?;

    // Disconnect
    connection.disconnect()?;

    Ok(())
}

Trait Implementations

impl Default for WsTransport

fn default() -> WsTransport

Returns the "default value" for a type.

impl Transport for WsTransport

fn accepts(&self, address: &str) -> bool

Indicates whether or not a given address can be used to create a connection or listener.

fn connect(
    &mut self,
    endpoint: &str
) -> Result<Box<dyn Connection>, ConnectError>

fn listen(&mut self, bind: &str) -> Result<Box<dyn Listener>, ListenError>