Struct scoped_stream_sink::Chain
source · pub struct Chain<U, V, II> { /* private fields */ }
Expand description
Return type of StreamSinkExt::chain()
.
Trait Implementations§
source§impl<U, V, SI, II, RI> StreamSink<SI, RI> for Chain<U, V, II>
impl<U, V, SI, II, RI> StreamSink<SI, RI> for Chain<U, V, II>
§type Error = <U as StreamSink<II, RI>>::Error
type Error = <U as StreamSink<II, RI>>::Error
The error type that it may return.
source§fn poll_stream_sink(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> State<SI, Self::Error>
fn poll_stream_sink( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> State<SI, Self::Error>
Poll the
StreamSink
. Read moresource§fn start_send(self: Pin<&mut Self>, item: RI) -> Result<(), Self::Error>
fn start_send(self: Pin<&mut Self>, item: RI) -> Result<(), Self::Error>
Starts sending item into
StreamSink
. Read moreimpl<'__pin, U, V, II> Unpin for Chain<U, V, II>where
__Origin<'__pin, U, V, II>: Unpin,
Auto Trait Implementations§
impl<U, V, II> Freeze for Chain<U, V, II>
impl<U, V, II> RefUnwindSafe for Chain<U, V, II>
impl<U, V, II> Send for Chain<U, V, II>
impl<U, V, II> Sync for Chain<U, V, II>
impl<U, V, II> UnwindSafe for Chain<U, V, II>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<SI, RI, T> StreamSinkExt<SI, RI> for Twhere
T: StreamSink<SI, RI>,
impl<SI, RI, T> StreamSinkExt<SI, RI> for Twhere
T: StreamSink<SI, RI>,
source§fn error_cast<E>(self) -> ErrorCast<Self, E>
fn error_cast<E>(self) -> ErrorCast<Self, E>
Cast the error type.
source§fn chain<Other, Item>(self, other: Other) -> Chain<Self, Other, SendItem>
fn chain<Other, Item>(self, other: Other) -> Chain<Self, Other, SendItem>
Chain two
StreamSink
. Read moresource§fn send_one<'a>(
self: Pin<&'a mut Self>,
item: RecvItem,
) -> SendOne<'a, Self, SendItem, RecvItem, Self::Error>
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>
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 moresource§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>
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 moresource§fn close<'a>(self: Pin<&'a mut Self>) -> Close<'a, Self, SendItem, RecvItem>
fn close<'a>(self: Pin<&'a mut Self>) -> Close<'a, Self, SendItem, RecvItem>
Closes the
StreamSink
. Read moresource§fn try_send_one<'a, F: FnOnce() -> RecvItem>(
self: Pin<&'a mut Self>,
f: F,
) -> TrySendOne<'a, Self, SendItem, F> ⓘ
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.