Struct ockam_transport_websocket::WebSocketTransport [−][src]
pub struct WebSocketTransport { /* fields omitted */ }
Expand description
High level management interface for WebSocket transports
Be aware that only one WebSocketTransport
can exist per node, as it
registers itself as a router for the WS
address type. Multiple
calls to WebSocketTransport::create
will fail.
To register additional connections on an already initialised
WebSocketTransport
, use
ws.connect()
. To listen for
incoming connections use
ws.listen()
use ockam_transport_websocket::WebSocketTransport;
let ws = WebSocketTransport::create(&ctx).await?;
ws.listen("127.0.0.1:8000").await?; // Listen on port 8000
ws.connect("127.0.0.1:5000").await?; // And connect to port 5000
The same WebSocketTransport
can also bind to multiple ports.
let ws = WebSocketTransport::create(&ctx).await?;
ws.listen("127.0.0.1:8000").await?; // Listen on port 8000
ws.listen("127.0.0.1:9000").await?; // Listen on port 9000
Implementations
Create a new WebSocket transport and router for the current node
Establish an outgoing WebSocket connection on an existing transport
Auto Trait Implementations
impl !RefUnwindSafe for WebSocketTransport
impl Send for WebSocketTransport
impl Sync for WebSocketTransport
impl Unpin for WebSocketTransport
impl !UnwindSafe for WebSocketTransport
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more