Struct body_image_futio::PermitBodySink [−][src]
pub struct PermitBodySink<B> where
B: InputBuf, { /* fields omitted */ }
Expand description
Extends AsyncBodySink
by acquiring a blocking permit before performing
any blocking file write operations.
The total number of concurrent blocking operations is constrained by the
Semaphore
referenced in
BlockingPolicy::Permit
from
FutioTunables::blocking_policy
, which is required.
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 PermitBodySink<B>
impl<B> Send for PermitBodySink<B>
impl<B> Sync for PermitBodySink<B>
impl<B> Unpin for PermitBodySink<B>
impl<B> !UnwindSafe for PermitBodySink<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