A layer over WebSocket enables carrying byte stream, for both native and WebAssembly.
Providing methods able to wrap any WebSocket message stream implementation,
and impl AsyncRead
,
AsyncBufRead
and AsyncWrite
.
run cargo add stream-ws
to bring it into your crate.
Examples in examples/
.
With feature tungstenite
.
For WebSocketStream
in either crate tokio-tungstenite
or async-tungstenite
,
use
let stream = stream_ws::tungstenite::WsByteStream::new(inner)
With feature gloo
.
For WebSocket
in crate gloo
use
let stream = stream_ws::gloo::WsByteStream::new(inner)
Your WebSocket implementation should have a struct S
satisfying trait bound
Stream<Item = Result<Msg, E>> + Sink<Msg, Error = E> + Unpin
where Msg
and E
are message and error type of the implementation.
Create a struct Handler
and impl
WsMessageHandle
,
which is easy, and then
call Handler::wrap_stream(underlying_stream)
to get a WsByteStream
.
tokio
: impltokio
'sAsyncRead
,AsyncBufRead
andAsyncWrite
variantstungstenite
: handlers for message and error type from cratetungstenite
gloo
: handlers for message and error type from crategloo
License: MIT OR Apache-2.0