pub enum SubscriptionError {
Io(Error),
Http(Error),
Deserialize(Error),
MissedChange {
expected: ChangeId,
got: ChangeId,
},
MaxLineLengthExceeded,
UnfinishedQuery,
MaxRetryAttempts,
}Expand description
Errors yielded by SubscriptionStream.
Variants§
Io(Error)
Underlying I/O error on the HTTP body.
Http(Error)
Generic HTTP error encountered while reconnecting.
Deserialize(Error)
A frame could not be decoded as a TypedQueryEvent.
MissedChange
The agent skipped a ChangeId, indicating the local view is no
longer consistent with the server.
MaxLineLengthExceeded
A single JSON line exceeded the codec’s maximum length.
UnfinishedQuery
The connection terminated before the initial query produced an
TypedQueryEvent::EndOfQuery.
MaxRetryAttempts
Error when maximum number of consecutive reconnect is exceeded.
Trait Implementations§
Source§impl Debug for SubscriptionError
impl Debug for SubscriptionError
Source§impl Display for SubscriptionError
impl Display for SubscriptionError
Source§impl Error for SubscriptionError
impl Error for SubscriptionError
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
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
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
Source§impl From<Error> for SubscriptionError
impl From<Error> for SubscriptionError
Source§impl From<Error> for SubscriptionError
impl From<Error> for SubscriptionError
Auto Trait Implementations§
impl Freeze for SubscriptionError
impl !RefUnwindSafe for SubscriptionError
impl Send for SubscriptionError
impl Sync for SubscriptionError
impl Unpin for SubscriptionError
impl UnsafeUnpin for SubscriptionError
impl !UnwindSafe for SubscriptionError
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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 moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ToCompactString for Twhere
T: Display,
impl<T> ToCompactString for Twhere
T: Display,
Source§fn to_compact_string(&self) -> CompactString
fn to_compact_string(&self) -> CompactString
Converts the given value to a
CompactString. Read moreSource§impl<T> ToStringFallible for Twhere
T: Display,
impl<T> ToStringFallible for Twhere
T: Display,
Source§fn try_to_string(&self) -> Result<String, TryReserveError>
fn try_to_string(&self) -> Result<String, TryReserveError>
ToString::to_string, but without panic on OOM.