pub type BufferedDrain<S, I> = DemuxDrain<I, Buffer<S, I>>;
Available on crate feature
deploy_integration
only.Aliased Type§
struct BufferedDrain<S, I> { /* private fields */ }
Trait Implementations
Source§impl<T, S> Sink<(u32, T)> for DemuxDrain<T, S>
impl<T, S> Sink<(u32, T)> for DemuxDrain<T, S>
Source§fn poll_ready(
self: Pin<&mut DemuxDrain<T, S>>,
_cx: &mut Context<'_>,
) -> Poll<Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>>
fn poll_ready( self: Pin<&mut DemuxDrain<T, S>>, _cx: &mut Context<'_>, ) -> Poll<Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>>
Attempts to prepare the
Sink
to receive a value. Read moreSource§fn start_send(
self: Pin<&mut DemuxDrain<T, S>>,
item: (u32, T),
) -> Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>
fn start_send( self: Pin<&mut DemuxDrain<T, S>>, item: (u32, T), ) -> Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>
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 moreSource§fn poll_flush(
self: Pin<&mut DemuxDrain<T, S>>,
_cx: &mut Context<'_>,
) -> Poll<Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>>
fn poll_flush( self: Pin<&mut DemuxDrain<T, S>>, _cx: &mut Context<'_>, ) -> Poll<Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>>
Flush any remaining output from this sink. Read more
Source§fn poll_close(
self: Pin<&mut DemuxDrain<T, S>>,
_cx: &mut Context<'_>,
) -> Poll<Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>>
fn poll_close( self: Pin<&mut DemuxDrain<T, S>>, _cx: &mut Context<'_>, ) -> Poll<Result<(), <DemuxDrain<T, S> as Sink<(u32, T)>>::Error>>
Flush any remaining output and close this sink, if necessary. Read more