pub enum ReceiveMessageError {
LostMessages(u64),
}
Expand description
Error type returned when reading message bytes from a messages stream.
Variants§
LostMessages(u64)
Error indicating that some buffered messages were deleted due to buffer capacity overflow.
If you don’t care about deleted messages, you can ignore this error (manually or using TryMessageStreamExt::ignore_lost_messages
).
Includes the number of deleted messages.
See ProcessManagerHandle::subscribe_message_stream
for more information.
Trait Implementations§
Source§impl Debug for ReceiveMessageError
impl Debug for ReceiveMessageError
Source§impl Display for ReceiveMessageError
impl Display for ReceiveMessageError
Source§impl Error for ReceiveMessageError
impl Error for ReceiveMessageError
1.30.0 · 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<BroadcastStreamRecvError> for ReceiveMessageError
impl From<BroadcastStreamRecvError> for ReceiveMessageError
Source§fn from(err: BroadcastStreamRecvError) -> Self
fn from(err: BroadcastStreamRecvError) -> Self
Converts to this type from the input type.
Source§impl From<ReceiveMessageError> for ReceiveDeserializedMessageError
impl From<ReceiveMessageError> for ReceiveDeserializedMessageError
Source§fn from(value: ReceiveMessageError) -> Self
fn from(value: ReceiveMessageError) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl Freeze for ReceiveMessageError
impl RefUnwindSafe for ReceiveMessageError
impl Send for ReceiveMessageError
impl Sync for ReceiveMessageError
impl Unpin for ReceiveMessageError
impl UnwindSafe for ReceiveMessageError
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