pub struct LastError(/* private fields */);Expand description
The last reason a stream closed, for error messages of calls that wait on a stream.
Implementations§
Source§impl LastError
impl LastError
Sourcepub fn set(&self, msg: impl Into<String>)
pub fn set(&self, msg: impl Into<String>)
Remembers the reason the stream closed, replacing an earlier one.
Sourcepub fn get(&self) -> Option<String>
pub fn get(&self) -> Option<String>
The last reason, if the stream is down now.
§Examples
use brokapi_tbank::stream::LastError;
let last = LastError::default();
assert_eq!(last.get(), None);
last.set("order_state: closed by the server");
assert_eq!(last.get().as_deref(), Some("order_state: closed by the server"));
last.clear();
assert_eq!(last.get(), None);Trait Implementations§
Auto Trait Implementations§
impl !Freeze for LastError
impl RefUnwindSafe for LastError
impl Send for LastError
impl Sync for LastError
impl Unpin for LastError
impl UnsafeUnpin for LastError
impl UnwindSafe for LastError
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].