StreamSinkPair

scoped_stream_sink

Struct StreamSinkPair 

Source 
pub struct StreamSinkPair<S, R> { /* private fields */ }
Expand description

Wraps a pair of Stream and Sink. Implements StreamSink.

Implementations§

Source§

impl<S, R> StreamSinkPair<S, R>

Source

pub fn new(stream: S, sink: R) -> Self

Creates new StreamSinkPair.

Source

pub fn get_pair(&mut self) -> (Option<&mut S>, &mut R)

Gets reference for inner data.

Source

pub fn get_pinned_pair( self: Pin<&mut Self>, ) -> (Option<Pin<&mut S>>, Pin<&mut R>)

Gets pinned reference for inner data.

Source

pub fn unwrap_pair(self) -> (Option<S>, R)

Unwraps self into it’s content.

Trait Implementations§

Source§

impl<S, R, Is, Ir, E> StreamSink<Is, Ir> for StreamSinkPair<S, R>
where S: Stream<Item = Result<Is, E>>, R: Sink<Ir, Error = E>,

Source§

type Error = E

The error type that it may return.
Source§

fn poll_stream_sink( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> State<Is, Self::Error>

Poll the StreamSink. Read more
Source§

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

Starts sending item into StreamSink. Read more
Source§

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

Close the StreamSink from outside. Implementation must be idempotent. Read more
Source§

impl<'__pin, S, R> Unpin for StreamSinkPair<S, R>
where PinnedFieldsOf<__Origin<'__pin, S, R>>: Unpin,

Auto Trait Implementations§

§

impl<S, R> Freeze for StreamSinkPair<S, R>
where R: Freeze, S: Freeze,

§

impl<S, R> RefUnwindSafe for StreamSinkPair<S, R>
where R: RefUnwindSafe, S: RefUnwindSafe,

§

impl<S, R> Send for StreamSinkPair<S, R>
where R: Send, S: Send,

§

impl<S, R> Sync for StreamSinkPair<S, R>
where R: Sync, S: Sync,

§

impl<S, R> UnwindSafe for StreamSinkPair<S, R>
where R: UnwindSafe, S: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<SI, RI, T> StreamSinkExt<SI, RI> for T
where T: StreamSink<SI, RI>,

Source§

fn map_send<F, I>(self, f: F) -> MapSend<Self, F, SendItem>
where Self: Sized, F: FnMut(SendItem) -> I,

Maps the SendItem.
Source§

fn map_recv<F, I>(self, f: F) -> MapRecv<Self, F, I>
where Self: Sized, F: FnMut(I) -> RecvItem,

Maps the RecvItem.
Source§

fn map_error<F, E>(self, f: F) -> MapError<Self, F>
where Self: Sized, F: FnMut(Self::Error) -> E,

Maps the error type.
Source§

fn error_cast<E>(self) -> ErrorCast<Self, E>
where Self: Sized, Self::Error: Into<E>,

Cast the error type.
Source§

fn chain<Other, Item>(self, other: Other) -> Chain<Self, Other, SendItem>
where Self: Sized, Other: StreamSink<Item, SendItem, Error = Self::Error>,

Chain two StreamSink. Read more
Source§

fn send_one<'a>( self: Pin<&'a mut Self>, item: RecvItem, ) -> SendOne<'a, Self, SendItem, RecvItem, Self::Error>

Send one item. Read more
Source§

fn send_iter<'a, I: IntoIterator<Item = RecvItem>>( self: Pin<&'a mut Self>, iter: I, ) -> SendIter<'a, Self, SendItem, RecvItem, I::IntoIter, Self::Error>

Send items from an IntoIterator. Read more
Source§

fn send_try_iter<'a, I: IntoIterator<Item = Result<RecvItem, Self::Error>>>( self: Pin<&'a mut Self>, iter: I, ) -> SendTryIter<'a, Self, SendItem, RecvItem, I::IntoIter, Self::Error>

Send items from a fallible IntoIterator. Read more
Source§

fn close<'a>(self: Pin<&'a mut Self>) -> Close<'a, Self, SendItem, RecvItem>

Closes the StreamSink. Read more
Source§

fn ready<'a>(self: Pin<&'a mut Self>) -> Ready<'a, Self, SendItem, RecvItem> ⓘ

Polls until it’s ready. It is safe drop the Future before it’s ready (cancel-safety). Read more
Source§

fn try_send_one<'a, F: FnOnce() -> RecvItem>( self: Pin<&'a mut Self>, f: F, ) -> TrySendOne<'a, Self, SendItem, F> ⓘ

Try to send an item. It is safe to drop the Future before it’s ready.
Source§

fn try_send_future<'a, F: Future<Output = Result<RecvItem, Self::Error>>>( self: Pin<&'a mut Self>, fut: F, ) -> TrySendFuture<'a, Self, SendItem, F> ⓘ

Try to send an item using Future. It is cancen-safe if and only if the inner Future is also cancel-safe.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.