Struct TryBufferUnordered

#[must_use = "streams do nothing unless polled"]
pub struct TryBufferUnordered<St>
where
    St: TryStream, { /* private fields */ }

Stream for the try_buffer_unordered method.

Implementations

impl<St> TryBufferUnordered<St> where St: TryStream, St::Ok: TryFuture,

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 TryBufferUnordered<St> where PinnedFieldsOf<__Origin<'__pin, St>>: Unpin, St: TryStream,

impl<S, Item, E> Sink<Item> for TryBufferUnordered<S> where S: TryStream + Sink<Item, Error = E>, S::Ok: TryFuture<Error = E>,

type Error = E;
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>>

impl<St> Debug for TryBufferUnordered<St> where St: TryStream + Debug, St::Ok: Debug,

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

impl<St> Stream for TryBufferUnordered<St> where St: TryStream, St::Ok: TryFuture<Error = St::Error>,

type Item = Result<<<St as TryStream>::Ok as TryFuture>::Ok, <St as TryStream>::Error>;
fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>>

Auto Trait Implementations

impl<St> !Freeze for TryBufferUnordered<St>

impl<St> !RefUnwindSafe for TryBufferUnordered<St>

impl<St> !UnwindSafe for TryBufferUnordered<St>

impl<St> Send for TryBufferUnordered<St> where Fuse<IntoStream<St>>: Send, FuturesUnordered<IntoFuture<<St as TryStream>::Ok>>: Send,

impl<St> Sync for TryBufferUnordered<St> where Fuse<IntoStream<St>>: Sync, FuturesUnordered<IntoFuture<<St as TryStream>::Ok>>: Sync,

impl<St> UnsafeUnpin for TryBufferUnordered<St> where Fuse<IntoStream<St>>: UnsafeUnpin, FuturesUnordered<IntoFuture<<St as TryStream>::Ok>>: UnsafeUnpin,

Blanket Implementations

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

impl<S, T, E> TryStream for TryBufferUnordered<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 TryBufferUnordered<St> where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for TryBufferUnordered<St>

fn from(t: T) -> T

Returns the argument unchanged.

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

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

impl<T, U> Into<U> for TryBufferUnordered<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 TryBufferUnordered<St> where U: Into<T>,

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

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

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