Struct tk_bufstream::WriteFramed
[−]
[src]
pub struct WriteFramed<T, C>(_, _);
A Sink
interface to WriteBuf
object
Methods
impl<T, C> WriteFramed<T, C>
[src]
fn get_ref(&self) -> &WriteBuf<T>
Returns a reference to the underlying I/O stream wrapped by WriteFramed
.
fn get_mut(&mut self) -> &mut WriteBuf<T>
Returns a mutable reference to the underlying I/O stream wrapped by
WriteFramed
.
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.
fn into_inner(self) -> WriteBuf<T>
Consumes the WriteFramed
, returning its underlying I/O stream.
Note that stream may contain both input and output data buffered.
Trait Implementations
impl<T: AsyncWrite, C: Encode> Sink for WriteFramed<T, C>
[src]
type SinkItem = C::Item
The type of value that the sink accepts.
type SinkError = Error
The type of value produced by the sink when an error occurs.
fn start_send(&mut self, item: C::Item) -> StartSend<C::Item, Error>
Begin the process of sending a value to the sink. Read more
fn poll_complete(&mut self) -> Poll<(), Error>
Flush all output from this sink, if necessary. Read more
fn close(&mut self) -> Result<Async<()>, Self::SinkError>
A method to indicate that no more values will ever be pushed into this sink. Read more
fn wait(self) -> Wait<Self>
Creates a new object which will produce a synchronous sink. Read more
fn with<U, F, Fut>(self, f: F) -> With<Self, U, F, Fut> where
F: FnMut(U) -> Fut,
Fut: IntoFuture<Item = Self::SinkItem>,
<Fut as IntoFuture>::Error: From<Self::SinkError>,
F: FnMut(U) -> Fut,
Fut: IntoFuture<Item = Self::SinkItem>,
<Fut as IntoFuture>::Error: From<Self::SinkError>,
Composes a function in front of the sink. Read more
fn sink_map_err<F, E>(self, f: F) -> SinkMapErr<Self, F> where
F: FnOnce(Self::SinkError) -> E,
F: FnOnce(Self::SinkError) -> E,
Transforms the error returned by the sink.
fn sink_from_err<E>(self) -> SinkFromErr<Self, E> where
E: From<Self::SinkError>,
E: From<Self::SinkError>,
Map this sink's error to any error implementing From
for this sink's Error
, returning a new sink. Read more
fn buffer(self, amt: usize) -> Buffer<Self>
Adds a fixed-size buffer to the current sink. Read more
fn flush(self) -> Flush<Self>
A future that completes when the sink has finished processing all pending requests. Read more
fn send(self, item: Self::SinkItem) -> Send<Self>
A future that completes after the given item has been fully processed into the sink, including flushing. Read more
fn send_all<S>(self, stream: S) -> SendAll<Self, S> where
S: Stream<Item = Self::SinkItem>,
Self::SinkError: From<<S as Stream>::Error>,
S: Stream<Item = Self::SinkItem>,
Self::SinkError: From<<S as Stream>::Error>,
A future that completes after the given stream has been fully processed into the sink, including flushing. Read more