Struct MessageCodec

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

protocol message reader/writer

Implementations

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

pub fn new(stream: S) -> Self

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

get mutable ref of underlying stream

pub fn receive( &mut self, ) -> Result<OneOf3<RequestMessage, ResponseMessage, NotificationMessage>>

read message from peer

for server, most of times coming messages are request or notification, at some rare case, there maybe a response, see applyEdit

pub fn send( &mut self, message: OneOf3<RequestMessage, ResponseMessage, NotificationMessage>, ) -> Result<()>

write message to peer

pub fn send_req(&mut self, message: RequestMessage) -> Result<()>

helper function to send request only

pub fn send_resp(&mut self, message: ResponseMessage) -> Result<()>

helper function to send response only

pub fn send_notice(&mut self, message: NotificationMessage) -> Result<()>

helper function to send notification only