Struct SinkPart 

pub struct SinkPart<'scope, 'env: 'scope, SI, RI, E> { /* private fields */ }

Sink half of inner ScopedStreamSink. Can receive both send type or a Result type. Closing will complete when outer ScopedStreamSink is closed and received all data.

Note About Thread-safety

Even though SinkPart is both Send and Sink, it’s reference should not be sent across thread. This is currently impossible, due to lack of async version of scope. To future-proof that possibility, any usage of it will panic if called from different thread than the outer thread. It also may panics outer thread too.

Also do note that some of the check depends on debug_assertions build config (AKA only on debug builds).

Trait Implementations

impl<'scope, 'env, SI, RI, E> Sink<Result<SI, E>> for SinkPart<'scope, 'env, SI, RI, E>

Available on crate feature std only.

type Error = Infallible

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn poll_flush( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn start_send( self: Pin<&mut Self>, item: Result<SI, E>, ) -> Result<(), Self::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(())).

fn poll_close( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.

impl<'scope, 'env, SI, RI, E> Sink<SI> for SinkPart<'scope, 'env, SI, RI, E>

Available on crate feature std only.

type Error = Infallible

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn start_send(self: Pin<&mut Self>, item: SI) -> Result<(), Self::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(())).

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.

impl<'__pin, 'scope, 'env: 'scope, SI, RI, E> Unpin for SinkPart<'scope, 'env, SI, RI, E>

where PinnedFieldsOf<__Origin<'__pin, 'scope, 'env, SI, RI, E>>: Unpin,