Struct ErrInto
#[must_use = "futures/streams/sinks do nothing unless you `.await` or poll them"]
pub struct ErrInto<St, E> { /* private fields */ }Stream for the err_into method.
Implementations
impl<St, E> ErrInto<St, E>
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, E> Unpin for ErrInto<St, E>
where
PinnedFieldsOf<__Origin<'__pin, St, E>>: Unpin,
impl<St, E> Debug for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: Debug,
fn fmt(&self, f: &mut Formatter<'_>) -> Result
impl<St, E> FusedStream for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: FusedStream,
fn is_terminated(&self) -> bool
impl<St, E> Stream for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: Stream,
type Item = <MapErr<St, IntoFn<E>> 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, E> Sink<_Item> for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: Sink<_Item>,
type Error = <MapErr<St, IntoFn<E>> 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, E> Freeze for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: Freeze,
impl<St, E> RefUnwindSafe for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: RefUnwindSafe,
impl<St, E> Send for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: Send,
impl<St, E> Sync for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: Sync,
impl<St, E> UnsafeUnpin for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: UnsafeUnpin,
impl<St, E> UnwindSafe for ErrInto<St, E>
where
MapErr<St, IntoFn<E>>: UnwindSafe,
Blanket Implementations
impl<S> TryStreamExt for ErrInto<St, E>
where
S: TryStream + ?Sized,
impl<S, T, E> TryStream for ErrInto<St, E>
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 ErrInto<St, E>
where
T: 'static + ?Sized,
fn type_id(&self) -> TypeId
impl<T> Borrow<T> for ErrInto<St, E>
where
T: ?Sized,
fn borrow(&self) -> &T
impl<T> BorrowMut<T> for ErrInto<St, E>
where
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
impl<T> From<T> for ErrInto<St, E>
fn from(t: T) -> TReturns the argument unchanged.
impl<T> StreamExt for ErrInto<St, E>
where
T: Stream + ?Sized,
impl<T, Item> SinkExt<Item> for ErrInto<St, E>
where
T: Sink<Item> + ?Sized,
impl<T, U> Into<U> for ErrInto<St, E>
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 ErrInto<St, E>
where
U: Into<T>,
type Error = never;fn try_from(value: U) -> Result<T, never>
impl<T, U> TryInto<U> for ErrInto<St, E>
where
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error;fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>