Struct ws_tool::codec::BytesCodec

pub struct BytesCodec<S: Read + Write> { /* private fields */ }

recv/send bytes message

Implementations

impl<S: Read + Write> BytesCodec<S>

pub fn new(stream: S) -> Self

construct method

pub fn new_with(stream: S, config: FrameConfig) -> Self

construct with stream & config

pub fn factory(_req: Request<()>, stream: S) -> Result<Self, WsError>

used for server side to construct a new server

pub fn check_fn( key: String, resp: Response<()>, stream: S ) -> Result<Self, WsError>

used to client side to construct a new client

pub fn stream_mut(&mut self) -> &mut S

get mutable underlying stream

pub fn receive(&mut self) -> Result<Message<BytesMut>, WsError>

receive a message

pub fn send<'a, T: Into<Message<&'a [u8]>>>( &mut self, msg: T ) -> Result<(), WsError>

send a message

pub fn flush(&mut self) -> Result<(), WsError>

flush underlying stream

impl<R, W, S> BytesCodec<S>where R: Read, W: Write, S: Read + Write + Split<R = R, W = W>,

pub fn split(self) -> (BytesRecv<R>, BytesSend<W>)

split codec to recv and send parts