Skip to main content

StreamError

Enum StreamError

pub enum StreamError {
    Connection {
        source: ConnectionError,
    },
    Reset {
        code: VarInt,
    },
}

Variants§

Connection

Fields

§source: ConnectionError

Reset

Fields

§code: VarInt

Implementations§

impl StreamError

pub fn is_reset(&self) -> bool

Returns true if the stream error is Reset.

Trait Implementations§

impl Clone for StreamError

fn clone(&self) -> StreamError

Returns a duplicate of the value. Read more

1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more

impl Debug for StreamError

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

Formats the value using the given formatter. Read more

impl Display for StreamError

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

Formats the value using the given formatter. Read more

impl Error for StreamError
where Self: Debug + Display,

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any. Read more

1.0.0 · Source§

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

1.0.0 · Source§

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports. Read more

impl ErrorCompat for StreamError

fn backtrace(&self) -> Option<&Backtrace>

Returns a Backtrace that may be printed.

fn iter_chain(&self) -> ChainCompat<'_, '_> ⓘ
where Self: AsErrorSource,

Returns an iterator for traversing the chain of errors, starting with the current error and continuing with recursive calls to Error::source. Read more

impl From<ConnectionError> for StreamError
where ConnectionError: Into<ConnectionError>,

fn from(error: ConnectionError) -> Self

Converts to this type from the input type.

impl From<Error> for StreamError

fn from(error: Error) -> Self

Converts to this type from the input type.

impl From<Infallible> for StreamError

fn from(value: Infallible) -> Self

Converts to this type from the input type.

impl From<StreamError> for StreamDecodeError

fn from(error: StreamError) -> Self

Converts to this type from the input type.

impl From<StreamError> for StreamEncodeError

fn from(error: StreamError) -> Self

Converts to this type from the input type.

impl From<StreamError> for StreamError

fn from(value: StreamError) -> Self

Converts to this type from the input type.

impl From<StreamError> for MessageStreamError
where StreamError: Into<StreamError>,

fn from(error: StreamError) -> Self

Converts to this type from the input type.

impl From<StreamError> for InitialRawMessageStreamError
where StreamError: Into<StreamError>,

fn from(error: StreamError) -> Self

Converts to this type from the input type.

impl From<StreamError> for AcceptRawMessageStreamError
where StreamError: Into<StreamError>,

fn from(error: StreamError) -> Self

Converts to this type from the input type.

impl From<StreamError> for EncodeHeaderSectionError

fn from(error: StreamError) -> Self

Converts to this type from the input type.

impl From<StreamError> for Error

fn from(value: StreamError) -> Self

Converts to this type from the input type.

impl<StreamState, Read, Stop, ReadFuture, StopFuture, Item> GetStreamId<StreamError> for Unfold<StreamState, Read, Stop, ReadFuture, StopFuture, Item>
where StreamState: GetStreamId<StreamError> + Unpin,

fn poll_stream_id( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<VarInt, StreamError>>

impl<StreamState, Send, Flush, Close, Reset, SendFuture, FlushFuture, CloseFuture, ResetFuture, SinkError> GetStreamId<StreamError> for Unfold<StreamState, Send, Flush, Close, Reset, SendFuture, FlushFuture, CloseFuture, ResetFuture, SinkError>
where StreamState: GetStreamId<StreamError> + Unpin,

fn poll_stream_id( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<VarInt, StreamError>>

impl GetStreamId<StreamError> for MessageReader

fn poll_stream_id( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<VarInt, StreamError>>

impl GetStreamId<StreamError> for MessageWriter

fn poll_stream_id( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<VarInt, StreamError>>

impl GetStreamId<StreamError> for dyn ReadStream

fn poll_stream_id( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<VarInt, StreamError>>

impl GetStreamId<StreamError> for dyn WriteStream

fn poll_stream_id( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<VarInt, StreamError>>

impl<T0> IntoError<StreamError> for ResetSnafu<T0>
where StreamError: Error + ErrorCompat, __T0: Into<VarInt>,

type Source = NoneError

The underlying error

fn into_error(self, error: Self::Source) -> StreamError

Combine the information to produce the error

impl<StreamState, Send, Flush, Close, Reset, SendFuture, FlushFuture, CloseFuture, ResetFuture, SinkError> ResetStream<StreamError> for Unfold<StreamState, Send, Flush, Close, Reset, SendFuture, FlushFuture, CloseFuture, ResetFuture, SinkError>
where Reset: FnMut(StreamState, VarInt) -> ResetFuture, SendFuture: Future<Output = Either<(StreamState, Result<(), SinkError>), StreamState>>, FlushFuture: Future<Output = Either<(StreamState, Result<(), SinkError>), StreamState>>, CloseFuture: Future<Output = Either<(StreamState, Result<(), SinkError>), StreamState>>, ResetFuture: Future<Output = (StreamState, Result<(), StreamError>)>, SinkError: From<StreamError>,

fn poll_reset( self: Pin<&mut Self>, cx: &mut Context<'_>, code: VarInt, ) -> Poll<Result<(), StreamError>>

impl ResetStream<StreamError> for MessageWriter

fn poll_reset( self: Pin<&mut Self>, cx: &mut Context<'_>, code: VarInt, ) -> Poll<Result<(), StreamError>>

impl ResetStream<StreamError> for dyn WriteStream

fn poll_reset( self: Pin<&mut Self>, cx: &mut Context<'_>, code: VarInt, ) -> Poll<Result<(), StreamError>>

impl<StreamState, Read, Stop, ReadFuture, StopFuture, Item> StopStream<StreamError> for Unfold<StreamState, Read, Stop, ReadFuture, StopFuture, Item>
where Read: FnMut(StreamState, CancellationToken) -> ReadFuture, ReadFuture: Future<Output = Either<(StreamState, Option<Item>), StreamState>>, Stop: FnMut(StreamState, VarInt) -> StopFuture, StopFuture: Future<Output = (StreamState, Result<(), StreamError>)>,

fn poll_stop( self: Pin<&mut Self>, cx: &mut Context<'_>, code: VarInt, ) -> Poll<Result<(), StreamError>>

impl StopStream<StreamError> for MessageReader

fn poll_stop( self: Pin<&mut Self>, cx: &mut Context<'_>, code: VarInt, ) -> Poll<Result<(), StreamError>>

impl StopStream<StreamError> for dyn ReadStream

fn poll_stop( self: Pin<&mut Self>, cx: &mut Context<'_>, code: VarInt, ) -> Poll<Result<(), StreamError>>

Auto Trait Implementations§

impl Freeze for StreamError

impl RefUnwindSafe for StreamError

impl Send for StreamError

impl Sync for StreamError

impl Unpin for StreamError

impl UnsafeUnpin for StreamError

impl UnwindSafe for StreamError

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> AsErrorSource for T
where T: Error + 'static,

fn as_error_source(&self) -> &(dyn Error + 'static)

For maximum effectiveness, this needs to be called as a method to benefit from Rust’s automatic dereferencing of method receivers.

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> CloneToUninit for T
where T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

impl<S> DecodeExt for S
where S: ?Sized,

fn decode<T>(self) -> impl Future<Output = Result<T, T::Error>> + Send
where Self: Sized, T: DecodeFrom<Self>,

fn decode_one<'s, T>(&'s mut self) -> impl Future<Output = Result<T, T::Error>>
where T: DecodeFrom<&'s mut Self>,

fn into_decode_stream<T, Error>(self) -> impl Stream<Item = Result<T, Error>>
where Self: Sized, for<'s> T: DecodeFrom<&'s mut Self, Error = Error>, for<'s> &'s mut Self: AsyncBufRead, Error: From<Error>,

impl<S> EncodeExt for S
where S: ?Sized,

fn encode<T>( self, item: T, ) -> impl Future<Output = Result<T::Output, T::Error>> + Send
where Self: Sized, T: EncodeInto<Self>,

fn encode_one<'s, T>( &'s mut self, item: T, ) -> impl Future<Output = Result<T::Output, T::Error>>
where Self: Sized, T: EncodeInto<&'s mut Self>,

fn into_encode_sink<T, Error>(self) -> impl Sink<T, Error = Error>
where Self: Sized, for<'s> T: EncodeInto<&'s mut Self, Error = Error>,

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
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> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more

impl<T> ToOwned for T
where T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T> ToString for T
where T: Display + ?Sized,

fn to_string(&self) -> String

Converts the given value to a String. Read more

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

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

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

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

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

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more