[−][src]Struct tokio_codec::FramedWrite
A Sink of frames encoded to an AsyncWrite.
Methods
impl<T, E> FramedWrite<T, E> where
T: AsyncWrite,
E: Encoder, [src]
T: AsyncWrite,
E: Encoder,
pub fn new(inner: T, encoder: E) -> FramedWrite<T, E>[src]
Creates a new FramedWrite with the given encoder.
impl<T, E> FramedWrite<T, E>[src]
pub fn get_ref(&self) -> &T[src]
Returns a reference to the underlying I/O stream wrapped by
FramedWrite.
Note that care should be taken to not tamper with the underlying stream of data coming in as it may corrupt the stream of frames otherwise being worked with.
pub fn get_mut(&mut self) -> &mut T[src]
Returns a mutable reference to the underlying I/O stream wrapped by
FramedWrite.
Note that care should be taken to not tamper with the underlying stream of data coming in as it may corrupt the stream of frames otherwise being worked with.
pub fn into_inner(self) -> T[src]
Consumes the FramedWrite, returning its underlying I/O stream.
Note that care should be taken to not tamper with the underlying stream of data coming in as it may corrupt the stream of frames otherwise being worked with.
pub fn encoder(&self) -> &E[src]
Returns a reference to the underlying decoder.
pub fn encoder_mut(&mut self) -> &mut E[src]
Returns a mutable reference to the underlying decoder.
Trait Implementations
impl<T, U> Debug for FramedWrite<T, U> where
T: Debug,
U: Debug, [src]
T: Debug,
U: Debug,
impl<T, D> Stream for FramedWrite<T, D> where
T: Stream + Unpin,
D: Unpin, [src]
T: Stream + Unpin,
D: Unpin,
type Item = T::Item
Values yielded by the stream.
fn poll_next(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>>[src]
impl<T, I, E> Sink<I> for FramedWrite<T, E> where
T: AsyncWrite + Unpin,
E: Encoder<Item = I> + Unpin,
E::Error: From<Error>, [src]
T: AsyncWrite + Unpin,
E: Encoder<Item = I> + Unpin,
E::Error: From<Error>,
type Error = E::Error
The type of value produced by the sink when an error occurs.
fn poll_ready(
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Result<(), Self::Error>>[src]
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Result<(), Self::Error>>
fn start_send(self: Pin<&mut Self>, item: I) -> Result<(), Self::Error>[src]
fn poll_flush(
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Result<(), Self::Error>>[src]
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Result<(), Self::Error>>
fn poll_close(
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Result<(), Self::Error>>[src]
self: Pin<&mut Self>,
cx: &mut Context
) -> Poll<Result<(), Self::Error>>
Auto Trait Implementations
impl<T, E> Send for FramedWrite<T, E> where
E: Send,
T: Send,
E: Send,
T: Send,
impl<T, E> Unpin for FramedWrite<T, E> where
E: Unpin,
T: Unpin,
E: Unpin,
T: Unpin,
impl<T, E> Sync for FramedWrite<T, E> where
E: Sync,
T: Sync,
E: Sync,
T: Sync,
impl<T, E> UnwindSafe for FramedWrite<T, E> where
E: UnwindSafe,
T: UnwindSafe,
E: UnwindSafe,
T: UnwindSafe,
impl<T, E> RefUnwindSafe for FramedWrite<T, E> where
E: RefUnwindSafe,
T: RefUnwindSafe,
E: RefUnwindSafe,
T: RefUnwindSafe,
Blanket Implementations
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<S, T, E> TryStream for S where
S: Stream<Item = Result<T, E>> + ?Sized, [src]
S: Stream<Item = Result<T, E>> + ?Sized,