Struct futures::sink::Wait
[−]
[src]
#[must_use = "sinks do nothing unless used"]pub struct Wait<S> { /* fields omitted */ }
A sink combinator which converts an asynchronous sink to a blocking sink.
Created by the Sink::wait method, this function transforms any sink into a
blocking version. This is implemented by blocking the current thread when a
sink is otherwise unable to make progress.
Methods
impl<S: Sink> Wait<S>[src]
fn send(&mut self, value: S::SinkItem) -> Result<(), S::SinkError>
Sends a value to this sink, blocking the current thread until it's able to do so.
This function will take the value provided and call the underlying
sink's start_send function until it's ready to accept the value. If
the function returns NotReady then the current thread is blocked
until it is otherwise ready to accept the value.
Return value
If Ok(()) is returned then the value provided was successfully sent
along the sink, and if Err(e) is returned then an error occurred
which prevented the value from being sent.
fn flush(&mut self) -> Result<(), S::SinkError>
Flushes any buffered data in this sink, blocking the current thread until it's entirely flushed.
This function will call the underlying sink's poll_complete method
until it returns that it's ready to proceed. If the method returns
NotReady the current thread will be blocked until it's otherwise
ready to proceed.