Type Alias futures_util::stream::try_stream::try_flatten_unordered::InnerStreamItem
source · type InnerStreamItem<St> = <<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item as Stream>::Item;
Implementations§
source§impl<St> NestedTryStreamIntoEitherTryStream<St>where
St: TryStream,
St::Ok: TryStream + Unpin,
<St::Ok as TryStream>::Error: From<St::Error>,
impl<St> NestedTryStreamIntoEitherTryStream<St>where St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,
fn new(stream: St) -> Self
sourcepub fn get_ref(&self) -> &St
pub fn get_ref(&self) -> &St
Acquires a reference to the underlying sink or stream that this combinator is pulling from.
sourcepub fn get_mut(&mut self) -> &mut St
pub 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.
sourcepub fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut St>
pub 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.
sourcepub fn into_inner(self) -> St
pub 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§
source§impl<St> Debug for NestedTryStreamIntoEitherTryStream<St>where
St: TryStream + Debug,
St::Ok: TryStream + Unpin,
<St::Ok as TryStream>::Error: From<St::Error>,
impl<St> Debug for NestedTryStreamIntoEitherTryStream<St>where St: TryStream + Debug, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,
source§impl<St> FlowController<<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item, <<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item as Stream>::Item> for PropagateBaseStreamError<St>where
St: TryStream,
St::Ok: TryStream + Unpin,
<St::Ok as TryStream>::Error: From<St::Error>,
impl<St> FlowController<<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item, <<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item as Stream>::Item> for PropagateBaseStreamError<St>where St: TryStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,
source§fn next_step(
item: <NestedTryStreamIntoEitherTryStream<St> as Stream>::Item
) -> FlowStep<<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item, <<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item as Stream>::Item>
fn next_step( item: <NestedTryStreamIntoEitherTryStream<St> as Stream>::Item ) -> FlowStep<<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item, <<NestedTryStreamIntoEitherTryStream<St> as Stream>::Item as Stream>::Item>
FlowStep
describing the next flow step.source§impl<St> FusedStream for NestedTryStreamIntoEitherTryStream<St>where
St: TryStream + FusedStream,
St::Ok: TryStream + Unpin,
<St::Ok as TryStream>::Error: From<St::Error>,
impl<St> FusedStream for NestedTryStreamIntoEitherTryStream<St>where St: TryStream + FusedStream, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<St::Error>,
source§fn is_terminated(&self) -> bool
fn is_terminated(&self) -> bool
true
if the stream should no longer be polled.source§impl<St, Item> Sink<Item> for NestedTryStreamIntoEitherTryStream<St>where
St: TryStream + Sink<Item>,
St::Ok: TryStream + Unpin,
<St::Ok as TryStream>::Error: From<<St as TryStream>::Error>,
impl<St, Item> Sink<Item> for NestedTryStreamIntoEitherTryStream<St>where St: TryStream + Sink<Item>, St::Ok: TryStream + Unpin, <St::Ok as TryStream>::Error: From<<St as TryStream>::Error>,
source§fn poll_ready(
self: Pin<&mut Self>,
cx: &mut Context<'_>
) -> Poll<Result<(), Self::Error>>
fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Result<(), Self::Error>>
Sink
to receive a value. Read moresource§fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>
fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>
poll_ready
which returned Poll::Ready(Ok(()))
. Read more