Struct body_image_futio::DispatchBodySink [−][src]
pub struct DispatchBodySink<B> where
B: InputBuf, { /* fields omitted */ }
Expand description
Extends AsyncBodySink
by further dispatching any blocking file write
operations to a blocking_permit::DispatchPool
registered with the
current thread.
The implementation will panic if a DispatchPool
is not registered. Note
that any risk of out-of-order writes (for example, via 2+ dispatch threads)
is avoided, because each instance will have, at most, 1 pending dispatch
write operation Future
, that it drives to completion before accepting
further input buffers. Also the underlying BodySink
is owned for the life
of the instance and is not a cloneable handle.
Trait Implementations
type Error = FutioError
type Error = FutioError
The type of value produced by the sink when an error occurs.
Attempts to prepare the Sink
to receive a value. Read more
Begin the process of sending a value to the sink.
Each call to this function must be preceded by a successful call to
poll_ready
which returned Poll::Ready(Ok(()))
. Read more
Flush any remaining output from this sink. Read more
Flush any remaining output and close this sink, if necessary. Read more
Auto Trait Implementations
impl<B> !RefUnwindSafe for DispatchBodySink<B>
impl<B> Send for DispatchBodySink<B>
impl<B> Sync for DispatchBodySink<B>
impl<B> Unpin for DispatchBodySink<B>
impl<B> !UnwindSafe for DispatchBodySink<B>
Blanket Implementations
Mutably borrows from an owned value. Read more
Composes a function in front of the sink. Read more
Composes a function in front of the sink. Read more
Transforms the error returned by the sink.
Map this sink’s error to a different error type using the Into
trait. Read more
Adds a fixed-size buffer to the current sink. Read more
Fanout items to multiple sinks. Read more
Flush the sink, processing all pending items. Read more
A future that completes after the given item has been fully processed into the sink, including flushing. Read more
A future that completes after the given item has been received by the sink. Read more
A future that completes after the given stream has been fully processed into the sink, including flushing. Read more
Wrap this sink in an Either
sink, making it the left-hand variant
of that Either
. Read more
Wrap this stream in an Either
stream, making it the right-hand variant
of that Either
. Read more
A convenience method for calling Sink::poll_ready
on Unpin
sink types. Read more
A convenience method for calling Sink::start_send
on Unpin
sink types. Read more
A convenience method for calling Sink::poll_flush
on Unpin
sink types. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more