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<Cow<'_, [u8]>>, WsError>

receive a message

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

helper method to send ping message

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

helper method to send pong message

pub fn close<'a>(&mut self, code: u16, msg: &'a [u8]) -> Result<(), WsError>

helper method to send close message

pub fn send<'a, T: Into<Message<Cow<'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