Struct futures_util::stream::SplitSink
[−]
[src]
pub struct SplitSink<S: Sink> { /* fields omitted */ }
A Sink
part of the split pair
Methods
impl<S: Sink> SplitSink<S>
[src]
pub fn reunite(self, other: SplitStream<S>) -> Result<S, ReuniteError<S>>
[src]
Attempts to put the two "halves" of a split Stream + Sink
back
together. Succeeds only if the SplitStream<S>
and SplitSink<S>
are
a matching pair originating from the same call to Stream::split
.
Trait Implementations
impl<S: Debug + Sink> Debug for SplitSink<S> where
S::SinkItem: Debug,
[src]
S::SinkItem: Debug,
fn fmt(&self, __arg_0: &mut Formatter) -> Result
[src]
Formats the value using the given formatter. Read more
impl<S: Sink> Sink for SplitSink<S>
[src]
type SinkItem = S::SinkItem
The type of value that the sink accepts.
type SinkError = S::SinkError
The type of value produced by the sink when an error occurs.
fn poll_ready(&mut self, cx: &mut Context) -> Poll<(), S::SinkError>
[src]
Attempts to prepare the Sink
to receive a value. Read more
fn start_send(&mut self, item: S::SinkItem) -> Result<(), S::SinkError>
[src]
Begin the process of sending a value to the sink. Each call to this function must be proceeded by a successful call to poll_ready
which returned Ok(Async::Ready(()))
. Read more
fn poll_flush(&mut self, cx: &mut Context) -> Poll<(), S::SinkError>
[src]
Flush any remaining output from this sink. Read more
fn poll_close(&mut self, cx: &mut Context) -> Poll<(), S::SinkError>
[src]
Flush any remaining output and close this sink, if necessary. Read more