Struct TryStreamInner 

pub struct TryStreamInner<'scope, 'env: 'scope, T, E> { /* private fields */ }

Inner type of ScopedTryStream.

Implements Sink for both item type and a Result, allowing to send error (if you so choose).

Note About Thread-safety

Even though TryStreamInner 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, T, E> Sink<Result<T, E>> for TryStreamInner<'scope, 'env, T, 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<(), Infallible>>

Attempts to prepare the Sink to receive a value.

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

Flush any remaining output from this sink.

fn start_send( self: Pin<&mut Self>, item: Result<T, E>, ) -> Result<(), Infallible>

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<(), Infallible>>

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

impl<'scope, 'env, T, E> Sink<T> for TryStreamInner<'scope, 'env, T, 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<(), Infallible>>

Attempts to prepare the Sink to receive a value.

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

Flush any remaining output from this sink.

fn start_send(self: Pin<&mut Self>, item: T) -> Result<(), Infallible>

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<(), Infallible>>

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

impl<'__pin, 'scope, 'env: 'scope, T, E> Unpin for TryStreamInner<'scope, 'env, T, E>

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