Struct WeakScope
pub struct WeakScope { /* private fields */ }Available on crate feature
std only.Expand description
A Scope handle that observes without holding the drain open.
Implementations§
§impl WeakScope
impl WeakScope
pub const fn detached() -> WeakScope
pub const fn detached() -> WeakScope
The weak handle of Scope::detached: work outside any shutdown, never cancelled.
pub fn try_hold(&self) -> Result<Scope, ScopeClosed>
pub fn try_hold(&self) -> Result<Scope, ScopeClosed>
Hold the scope, as WeakScope::into_scope does, keeping this handle: the one fallible
step before starting work in it.
§Errors
ScopeClosed once the scope is closed.
pub fn into_scope(self) -> Option<Scope>
pub fn into_scope(self) -> Option<Scope>
Hold the scope again: refused once it is closed, and once it has no holder left while
cancelled (that closes it). A scope made by Scope::child_of is held again only as a
whole.
pub fn cancel(&self, cause: Cause)
pub fn cancel(&self, cause: Cause)
See Scope::cancel.
pub fn abort(&self, cause: Cause)
pub fn abort(&self, cause: Cause)
See Scope::abort.
pub fn cancelled(&self) -> Cancelled ⓘ
pub fn cancelled(&self) -> Cancelled ⓘ
See Scope::cancelled.
pub fn aborted(&self) -> Aborted ⓘ
pub fn aborted(&self) -> Aborted ⓘ
See Scope::aborted.
pub fn drained(&self) -> Drained ⓘ
pub fn drained(&self) -> Drained ⓘ
See Scope::drained.
pub fn is_cancelled(&self) -> bool
pub fn is_cancelled(&self) -> bool
See Scope::is_cancelled.
pub fn is_aborted(&self) -> bool
pub fn is_aborted(&self) -> bool
See Scope::is_aborted.
pub fn cause(&self) -> Option<Cause>
pub fn cause(&self) -> Option<Cause>
See Scope::cause.
pub fn abort_cause(&self) -> Option<Cause>
pub fn abort_cause(&self) -> Option<Cause>
See Scope::abort_cause.
pub const fn is_detached(&self) -> bool
pub const fn is_detached(&self) -> bool
See Scope::is_detached.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for WeakScope
impl !UnwindSafe for WeakScope
impl Forget for WeakScope
impl Freeze for WeakScope
impl Send for WeakScope
impl Sync for WeakScope
impl Unpin for WeakScope
impl UnsafeUnpin for WeakScope
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§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> ⓘ
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 more§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 rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Create a new
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more