Struct TryFlattenUnordered

#[must_use = "futures/streams/sinks do nothing unless you `.await` or poll them"]
pub struct TryFlattenUnordered<St>
where
    St: TryStream,
    St::Ok: TryStream + Unpin,
    <St::Ok as TryStream>::Error: From<St::Error>, { /* private fields */ }

Stream for the try_flatten_unordered method.

Implementations

impl<St> TryFlattenUnordered<St> where St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,

fn get_ref(&self) -> &St

Acquires a reference to the underlying sink or stream that this combinator is pulling from.

fn get_mut(&mut self) -> &mut St

Acquires a mutable reference to the underlying sink or stream that this combinator is pulling from.

Note that care must be taken to avoid tampering with the state of the sink or stream which may otherwise confuse this combinator.

fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut St>

Acquires a pinned mutable reference to the underlying sink or stream that this combinator is pulling from.

Note that care must be taken to avoid tampering with the state of the sink or stream which may otherwise confuse this combinator.

fn into_inner(self) -> St

Consumes this combinator, returning the underlying sink or stream.

Note that this may discard intermediate state of this combinator, so care should be taken to avoid losing resources when this is called.

Trait Implementations

impl<'__pin, St> Unpin for TryFlattenUnordered<St> where PinnedFieldsOf<__Origin<'__pin, St>>: Unpin, St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,

impl<St> Debug for TryFlattenUnordered<St> where FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: Debug, St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,

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

impl<St> FusedStream for TryFlattenUnordered<St> where FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: FusedStream, St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,

fn is_terminated(&self) -> bool

impl<St> Stream for TryFlattenUnordered<St> where FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: Stream, St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,

type Item = <FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>> as Stream>::Item;
fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>
fn size_hint(&self) -> (usize, Option<usize>)

impl<_Item, St> Sink<_Item> for TryFlattenUnordered<St> where FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: Sink<_Item>, St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,

type Error = <FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>> as Sink<_Item>>::Error;
fn poll_ready(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>
fn start_send(self: Pin<&mut Self>, item: _Item) -> Result<(), Self::Error>
fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>
fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Auto Trait Implementations

impl<St> !Freeze for TryFlattenUnordered<St>

impl<St> !RefUnwindSafe for TryFlattenUnordered<St>

impl<St> !UnwindSafe for TryFlattenUnordered<St>

impl<St> Send for TryFlattenUnordered<St> where <<St as TryStream>::Ok as TryStream>::Error: Sized, FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: Send,

impl<St> Sync for TryFlattenUnordered<St> where <<St as TryStream>::Ok as TryStream>::Error: Sized, FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: Sync,

impl<St> UnsafeUnpin for TryFlattenUnordered<St> where <<St as TryStream>::Ok as TryStream>::Error: Sized, FlattenUnorderedWithFlowController<NestedTryStreamIntoEitherTryStream<St>, PropagateBaseStreamError<St>>: UnsafeUnpin,

Blanket Implementations

impl<S> TryStreamExt for TryFlattenUnordered<St> where S: TryStream + ?Sized,

impl<S, T, E> TryStream for TryFlattenUnordered<St> where S: Stream<Item = Result<T, E>> + ?Sized,

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>>>

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for TryFlattenUnordered<St>

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> StreamExt for TryFlattenUnordered<St> where T: Stream + ?Sized,

impl<T, Item> SinkExt<Item> for TryFlattenUnordered<St> where T: Sink<Item> + ?Sized,

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

fn into(self) -> U

Calls U::from(self).

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

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

type Error = never;
fn try_from(value: U) -> Result<T, never>

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

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