Struct Party
pub struct Party { /* private fields */ }Available on crate feature
std only.Expand description
One waiting task. It queues a Waiter in each WaitQueue it waits in,
and any of them wakes it: see Self::woken.
Implementations§
§impl Party
impl Party
pub fn new(order: u64) -> Arc<Party> ⓘ
Available on crate features grpc and http only.
pub fn new(order: u64) -> Arc<Party> ⓘ
grpc and http only.Create a party, order being its arrival among its owner’s parties:
lower is older.
pub fn order(&self) -> u64
Available on crate features grpc and http only.
pub fn order(&self) -> u64
grpc and http only.Its arrival among its owner’s parties: lower is older.
pub fn waiter(self: &Arc<Party>) -> Waiter
Available on crate features grpc and http only.
pub fn waiter(self: &Arc<Party>) -> Waiter
grpc and http only.A place for the party in one more queue, to WaitQueue::push.
pub fn wakes(&self) -> usize
Available on crate features grpc and http only.
pub fn wakes(&self) -> usize
grpc and http only.How often its waiters were woken so far: read before a look.
pub fn woken(&self, seen: usize) -> Woken<'_> ⓘ
Available on crate features grpc and http only.
pub fn woken(&self, seen: usize) -> Woken<'_> ⓘ
grpc and http only.Completes once any of its waiters is woken after seen, the count of
Self::wakes read before the look: no wake between the look and the
wait is lost.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for Party
impl !RefUnwindSafe for Party
impl Send for Party
impl Sync for Party
impl Unpin for Party
impl UnsafeUnpin for Party
impl UnwindSafe for Party
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
§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