pub struct Writer<W> {
pub stream: W,
pub sender: Sender,
}
Expand description
A writer that bundles a stream with a serializer to send the messages.
This is used in the client’s .split()
function as the writing component.
It can also be useful to use a websocket connection without a handshake.
Fields§
§stream: W
The stream that websocket messages will be written to
sender: Sender
The serializer that will be used to serialize the messages
Implementations§
source§impl<W> Writer<W>where
W: Write,
impl<W> Writer<W>where
W: Write,
sourcepub fn send_dataframe<D>(&mut self, dataframe: &D) -> WebSocketResult<()>
pub fn send_dataframe<D>(&mut self, dataframe: &D) -> WebSocketResult<()>
Sends a single data frame to the remote endpoint.
sourcepub fn send_message<M>(&mut self, message: &M) -> WebSocketResult<()>where
M: Message,
pub fn send_message<M>(&mut self, message: &M) -> WebSocketResult<()>where
M: Message,
Sends a single message to the remote endpoint.
source§impl<S> Writer<S>where
S: AsTcpStream + Write,
impl<S> Writer<S>where
S: AsTcpStream + Write,
sourcepub fn shutdown(&self) -> IoResult<()>
pub fn shutdown(&self) -> IoResult<()>
Closes the sender side of the connection, will cause all pending and future IO to return immediately with an appropriate value.
sourcepub fn shutdown_all(&self) -> IoResult<()>
pub fn shutdown_all(&self) -> IoResult<()>
Shuts down both Sender and Receiver, will cause all pending and future IO to return immediately with an appropriate value.
Auto Trait Implementations§
impl<W> Freeze for Writer<W>where
W: Freeze,
impl<W> RefUnwindSafe for Writer<W>where
W: RefUnwindSafe,
impl<W> Send for Writer<W>where
W: Send,
impl<W> Sync for Writer<W>where
W: Sync,
impl<W> Unpin for Writer<W>where
W: Unpin,
impl<W> UnwindSafe for Writer<W>where
W: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more