Struct TryBuffered
#[must_use = "streams do nothing unless polled"]
pub struct TryBuffered<St>
where
St: TryStream,
St::Ok: TryFuture, { /* private fields */ }Stream for the try_buffered method.
Implementations
impl<St> TryBuffered<St>
where
St: TryStream,
St::Ok: TryFuture,
fn get_ref(&self) -> &StAcquires a reference to the underlying sink or stream that this combinator is pulling from.
fn get_mut(&mut self) -> &mut StAcquires 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) -> StConsumes 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 TryBuffered<St>
where
PinnedFieldsOf<__Origin<'__pin, St>>: Unpin,
St: TryStream,
St::Ok: TryFuture,
impl<S, Item, E> Sink<Item> for TryBuffered<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 TryBuffered<St>
where
St: TryStream + Debug,
St::Ok: TryFuture + Debug,
fn fmt(&self, f: &mut Formatter<'_>) -> Result
impl<St> Stream for TryBuffered<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 TryBuffered<St>
impl<St> !RefUnwindSafe for TryBuffered<St>
impl<St> !UnwindSafe for TryBuffered<St>
impl<St> Send for TryBuffered<St>
where
Fuse<IntoStream<St>>: Send,
FuturesOrdered<IntoFuture<<St as TryStream>::Ok>>: Send,
impl<St> Sync for TryBuffered<St>
where
Fuse<IntoStream<St>>: Sync,
FuturesOrdered<IntoFuture<<St as TryStream>::Ok>>: Sync,
impl<St> UnsafeUnpin for TryBuffered<St>
where
Fuse<IntoStream<St>>: UnsafeUnpin,
FuturesOrdered<IntoFuture<<St as TryStream>::Ok>>: UnsafeUnpin,
Blanket Implementations
impl<S> TryStreamExt for TryBuffered<St>
where
S: TryStream + ?Sized,
impl<S, T, E> TryStream for TryBuffered<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 TryBuffered<St>
where
T: 'static + ?Sized,
fn type_id(&self) -> TypeId
impl<T> Borrow<T> for TryBuffered<St>
where
T: ?Sized,
fn borrow(&self) -> &T
impl<T> BorrowMut<T> for TryBuffered<St>
where
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
impl<T> From<T> for TryBuffered<St>
fn from(t: T) -> TReturns the argument unchanged.
impl<T> StreamExt for TryBuffered<St>
where
T: Stream + ?Sized,
impl<T, Item> SinkExt<Item> for TryBuffered<St>
where
T: Sink<Item> + ?Sized,
impl<T, U> Into<U> for TryBuffered<St>
where
U: From<T>,
fn into(self) -> UCalls
U::from(self).That is, this conversion is whatever the implementation of
[From]<T> for Uchooses to do.
impl<T, U> TryFrom<U> for TryBuffered<St>
where
U: Into<T>,
type Error = never;fn try_from(value: U) -> Result<T, never>
impl<T, U> TryInto<U> for TryBuffered<St>
where
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error;fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>