[−][src]Struct futures_util::future::TryFlattenStream

#[must_use =
  "futures/streams/sinks do nothing unless you `.await` or poll them"]pub struct TryFlattenStream<Fut> where
    Fut: TryFuture,  { /* fields omitted */ }

Trait Implementations

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

Values yielded by the stream.

Auto Trait Implementations

Blanket Implementations

The type returned in the event of a conversion error.

The type returned in the event of a conversion error.

The type of successful values yielded by this future

The type of failures yielded by this future

[−][src]Struct futures_util::future::TryFlattenStream

Trait Implementations

impl<Fut> Debug for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: Debug, Fut: TryFuture, [src]

fn fmt(&self, f: &mut Formatter<'_>) -> Result[src]

impl<Fut> FusedStream for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: FusedStream, Fut: TryFuture, [src]

fn is_terminated(&self) -> bool[src]

impl<Fut> PinnedDrop for TryFlattenStream<Fut> where Fut: TryFuture, [src]

unsafe fn drop(self: Pin<&mut Self>)[src]

impl<_Item, Fut> Sink<_Item> for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: Sink<_Item>, Fut: TryFuture, [src]

type Error = <TryFlatten<Fut, Fut::Ok> as Sink<_Item>>::Error

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

fn start_send(self: Pin<&mut Self>, item: _Item) -> Result<(), Self::Error>[src]

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

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

impl<Fut> Stream for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: Stream, Fut: TryFuture, [src]

type Item = <TryFlatten<Fut, Fut::Ok> as Stream>::Item

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>[src]

fn size_hint(&self) -> (usize, Option<usize>)[src]

impl<'pin, Fut> Unpin for TryFlattenStream<Fut> where Fut: TryFuture, __TryFlattenStream<'pin, Fut>: Unpin, [src]

impl<Fut> UnsafeUnpin for TryFlattenStream<Fut> where Fut: TryFuture, [src]

Auto Trait Implementations

impl<Fut> RefUnwindSafe for TryFlattenStream<Fut> where Fut: RefUnwindSafe, <Fut as TryFuture>::Ok: RefUnwindSafe,

impl<Fut> Send for TryFlattenStream<Fut> where Fut: Send, <Fut as TryFuture>::Ok: Send,

impl<Fut> Sync for TryFlattenStream<Fut> where Fut: Sync, <Fut as TryFuture>::Ok: Sync,

impl<Fut> UnwindSafe for TryFlattenStream<Fut> where Fut: UnwindSafe, <Fut as TryFuture>::Ok: UnwindSafe,

Blanket Implementations

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

fn type_id(&self) -> TypeId[src]

impl<T> Borrow<T> for T where T: ?Sized, [src]

fn borrow(&self) -> &TⓘNotable traits for &'_ mut Fimpl<'_, F> Future for &'_ mut F where F: Unpin + Future + ?Sized, type Output = <F as Future>::Output;[src]

Notable traits for &'_ mut F

impl<T> BorrowMut<T> for T where T: ?Sized, [src]

fn borrow_mut(&mut self) -> &mut TⓘNotable traits for &'_ mut Fimpl<'_, F> Future for &'_ mut F where F: Unpin + Future + ?Sized, type Output = <F as Future>::Output;[src]

Notable traits for &'_ mut F

impl<T> From<T> for T[src]

fn from(t: T) -> T[src]

impl<T, U> Into<U> for T where U: From<T>, [src]

fn into(self) -> U[src]

impl<T, Item> SinkExt<Item> for T where T: Sink<Item> + ?Sized, [src]

fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where F: FnMut(U) -> Fut, Fut: Future<Output = Result<Item, E>>, E: From<Self::Error>, Self: Sized, [src]

fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where F: FnMut(U) -> St, St: Stream<Item = Result<Item, Self::Error>>, Self: Sized, [src]

fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where F: FnOnce(Self::Error) -> E, Self: Sized, [src]

fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where Self: Sized, Self::Error: Into<E>, [src]

fn buffer(self, capacity: usize) -> Buffer<Self, Item> where Self: Sized, [src]

fn close(&mut self) -> Close<'_, Self, Item>ⓘNotable traits for Close<'_, Si, Item>impl<Si: Sink<Item> + Unpin + ?Sized, Item, '_> Future for Close<'_, Si, Item> type Output = Result<(), Si::Error>; where Self: Unpin, [src]

Notable traits for Close<'_, Si, Item>

fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where Self: Sized, Item: Clone, Si: Sink<Item, Error = Self::Error>, [src]

fn flush(&mut self) -> Flush<'_, Self, Item>ⓘNotable traits for Flush<'_, Si, Item>impl<Si: Sink<Item> + Unpin + ?Sized, Item, '_> Future for Flush<'_, Si, Item> type Output = Result<(), Si::Error>; where Self: Unpin, [src]

Notable traits for Flush<'_, Si, Item>

fn send(&mut self, item: Item) -> Send<'_, Self, Item>ⓘNotable traits for Send<'_, Si, Item>impl<Si: Sink<Item> + Unpin + ?Sized, Item, '_> Future for Send<'_, Si, Item> type Output = Result<(), Si::Error>; where Self: Unpin, [src]

Notable traits for Send<'_, Si, Item>

Notable traits for SendAll<'_, Si, St>

fn left_sink<Si2>(self) -> Either<Self, Si2>ⓘNotable traits for Either<A, B>impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output; where Si2: Sink<Item, Error = Self::Error>, Self: Sized, [src]

Notable traits for Either<A, B>

fn right_sink<Si1>(self) -> Either<Si1, Self>ⓘNotable traits for Either<A, B>impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output; where Si1: Sink<Item, Error = Self::Error>, Self: Sized, [src]

Notable traits for Either<A, B>

fn poll_ready_unpin( &mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> where Self: Unpin, [src]

fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error> where Self: Unpin, [src]

fn poll_flush_unpin( &mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> where Self: Unpin, [src]

fn poll_close_unpin( &mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> where Self: Unpin, [src]

impl<T, U> TryFrom<U> for T where U: Into<T>, [src]

type Error = Infallible

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

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src]

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

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

impl<S, T, E> TryStream for S where S: Stream<Item = Result<T, E>> + ?Sized, [src]

type Ok = T

type Error = E

fn try_poll_next( self: Pin<&mut S>, cx: &mut Context<'_>) -> Poll<Option<Result<<S as TryStream>::Ok, <S as TryStream>::Error>>>[src]

`impl<Fut> Debug for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: Debug, Fut: TryFuture,` [src]

`fn fmt(&self, f: &mut Formatter<'_>) -> Result`[src]

`impl<Fut> FusedStream for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: FusedStream, Fut: TryFuture,` [src]

`fn is_terminated(&self) -> bool`[src]

`impl<Fut> PinnedDrop for TryFlattenStream<Fut> where Fut: TryFuture,` [src]

`unsafe fn drop(self: Pin<&mut Self>)`[src]

`impl<_Item, Fut> Sink<_Item> for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: Sink<_Item>, Fut: TryFuture,` [src]

`type Error = <TryFlatten<Fut, Fut::Ok> as Sink<_Item>>::Error`

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

`fn start_send(self: Pin<&mut Self>, item: _Item) -> Result<(), Self::Error>`[src]

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

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

`impl<Fut> Stream for TryFlattenStream<Fut> where TryFlatten<Fut, Fut::Ok>: Stream, Fut: TryFuture,` [src]

`type Item = <TryFlatten<Fut, Fut::Ok> as Stream>::Item`

`fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Option<Self::Item>>`[src]

`fn size_hint(&self) -> (usize, Option<usize>)`[src]

`impl<'pin, Fut> Unpin for TryFlattenStream<Fut> where Fut: TryFuture, __TryFlattenStream<'pin, Fut>: Unpin,` [src]

`impl<Fut> UnsafeUnpin for TryFlattenStream<Fut> where Fut: TryFuture,` [src]

`impl<Fut> RefUnwindSafe for TryFlattenStream<Fut> where Fut: RefUnwindSafe, <Fut as TryFuture>::Ok: RefUnwindSafe,`

`impl<Fut> Send for TryFlattenStream<Fut> where Fut: Send, <Fut as TryFuture>::Ok: Send,`

`impl<Fut> Sync for TryFlattenStream<Fut> where Fut: Sync, <Fut as TryFuture>::Ok: Sync,`

`impl<Fut> UnwindSafe for TryFlattenStream<Fut> where Fut: UnwindSafe, <Fut as TryFuture>::Ok: UnwindSafe,`

`impl<T> Any for T where T: 'static + ?Sized,` [src]

`fn type_id(&self) -> TypeId`[src]

`impl<T> Borrow<T> for T where T: ?Sized,` [src]

`fn borrow(&self) -> &TⓘNotable traits for &'_ mut F impl<'_, F> Future for &'_ mut F where F: Unpin + Future + ?Sized, type Output = <F as Future>::Output;`[src]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src]

`fn borrow_mut(&mut self) -> &mut TⓘNotable traits for &'_ mut F impl<'_, F> Future for &'_ mut F where F: Unpin + Future + ?Sized, type Output = <F as Future>::Output;`[src]

`impl<T> From<T> for T`[src]

`fn from(t: T) -> T`[src]

`impl<T, U> Into<U> for T where U: From<T>,` [src]

`fn into(self) -> U`[src]

`impl<T, Item> SinkExt<Item> for T where T: Sink<Item> + ?Sized,` [src]

`fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F> where F: FnMut(U) -> Fut, Fut: Future<Output = Result<Item, E>>, E: From<Self::Error>, Self: Sized,` [src]

`fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where F: FnMut(U) -> St, St: Stream<Item = Result<Item, Self::Error>>, Self: Sized,` [src]

`fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F> where F: FnOnce(Self::Error) -> E, Self: Sized,` [src]

`fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E> where Self: Sized, Self::Error: Into<E>,` [src]

`fn buffer(self, capacity: usize) -> Buffer<Self, Item> where Self: Sized,` [src]

`fn close(&mut self) -> Close<'_, Self, Item>ⓘNotable traits for Close<'_, Si, Item> impl<Si: Sink<Item> + Unpin + ?Sized, Item, '_> Future for Close<'_, Si, Item> type Output = Result<(), Si::Error>; where Self: Unpin,` [src]

`fn fanout<Si>(self, other: Si) -> Fanout<Self, Si> where Self: Sized, Item: Clone, Si: Sink<Item, Error = Self::Error>,` [src]

`fn flush(&mut self) -> Flush<'_, Self, Item>ⓘNotable traits for Flush<'_, Si, Item> impl<Si: Sink<Item> + Unpin + ?Sized, Item, '_> Future for Flush<'_, Si, Item> type Output = Result<(), Si::Error>; where Self: Unpin,` [src]

`fn send(&mut self, item: Item) -> Send<'_, Self, Item>ⓘNotable traits for Send<'_, Si, Item> impl<Si: Sink<Item> + Unpin + ?Sized, Item, '_> Future for Send<'_, Si, Item> type Output = Result<(), Si::Error>; where Self: Unpin,` [src]

`fn left_sink<Si2>(self) -> Either<Self, Si2>ⓘNotable traits for Either<A, B> impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output; where Si2: Sink<Item, Error = Self::Error>, Self: Sized,` [src]

`fn right_sink<Si1>(self) -> Either<Si1, Self>ⓘNotable traits for Either<A, B> impl<A, B> Future for Either<A, B> where A: Future, B: Future<Output = A::Output>, type Output = A::Output; where Si1: Sink<Item, Error = Self::Error>, Self: Sized,` [src]

`fn poll_ready_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src]

`fn start_send_unpin(&mut self, item: Item) -> Result<(), Self::Error> where Self: Unpin,` [src]

`fn poll_flush_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src]

`fn poll_close_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>> where Self: Unpin,` [src]

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src]

`type Error = Infallible`

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

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src]

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

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

`impl<S, T, E> TryStream for S where S: Stream<Item = Result<T, E>> + ?Sized,` [src]

`type Ok = T`

`type Error = E`

`fn try_poll_next( self: Pin<&mut S>, cx: &mut Context<'_> ) -> Poll<Option<Result<<S as TryStream>::Ok, <S as TryStream>::Error>>>`[src]