pub struct PortId(/* private fields */);Expand description
Port ids identify [crate::mailbox::Port]s of an actor.
TODO: consider moving [crate::mailbox::Port] to PortRef in this
module for consistency with actors,
Implementations§
Source§impl PortId
impl PortId
Sourcepub fn into_actor_id(self) -> ActorId
pub fn into_actor_id(self) -> ActorId
Convert this port ID into an actor ID.
Sourcepub fn send(&self, cx: &impl Actor, serialized: Any)
pub fn send(&self, cx: &impl Actor, serialized: Any)
Send a serialized message to this port, provided a sending capability,
such as [crate::actor::Instance]. It is the sender’s responsibility
to ensure that the provided message is well-typed.
Sourcepub fn send_with_headers(
&self,
cx: &impl Actor,
serialized: Any,
headers: Flattrs,
)
pub fn send_with_headers( &self, cx: &impl Actor, serialized: Any, headers: Flattrs, )
Send a serialized message to this port, provided a sending capability,
such as [crate::actor::Instance], with additional context provided by headers.
It is the sender’s responsibility to ensure that the provided message is well-typed.
Sourcepub fn split(
&self,
cx: &impl Actor,
reducer_spec: Option<ReducerSpec>,
reducer_mode: ReducerMode,
return_undeliverable: bool,
) -> Result<PortId>
pub fn split( &self, cx: &impl Actor, reducer_spec: Option<ReducerSpec>, reducer_mode: ReducerMode, return_undeliverable: bool, ) -> Result<PortId>
Split this port, returning a new port that relays messages to the port through a local proxy, which may coalesce messages.
Trait Implementations§
Source§impl<'de> Deserialize<'de> for PortId
impl<'de> Deserialize<'de> for PortId
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Source§impl Named for PortId
impl Named for PortId
Source§fn typename() -> &'static str
fn typename() -> &'static str
Source§fn typehash() -> u64
fn typehash() -> u64
Source§fn typeid() -> TypeId
fn typeid() -> TypeId
Source§fn port() -> u64
fn port() -> u64
Source§impl Ord for PortId
impl Ord for PortId
Source§impl PartialOrd for PortId
impl PartialOrd for PortId
impl Eq for PortId
impl StructuralPartialEq for PortId
Auto Trait Implementations§
impl Freeze for PortId
impl RefUnwindSafe for PortId
impl Send for PortId
impl Sync for PortId
impl Unpin for PortId
impl UnwindSafe for PortId
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
Source§impl<T> Checkpointable for Twhere
T: RemoteMessage + Clone,
impl<T> Checkpointable for Twhere
T: RemoteMessage + Clone,
Source§type State = T
type State = T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<Q, K> Comparable<K> for Q
impl<Q, K> Comparable<K> for Q
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.§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>
Source§impl<A, M> Handler<IndexedErasedUnbound<M>> for A
impl<A, M> Handler<IndexedErasedUnbound<M>> for A
§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>
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>
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>
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>,
Layered].§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§impl<T> QuoteExt for Twhere
T: ?Sized,
impl<T> QuoteExt for Twhere
T: ?Sized,
fn push_quoted<'q, Q, S>(&mut self, _q: Q, s: S)where
Q: QuoteInto<T>,
S: Into<Quotable<'q>>,
Source§impl<T> Serialize for T
impl<T> Serialize for T
fn erased_serialize(&self, serializer: &mut dyn Serializer) -> Result<(), Error>
fn do_erased_serialize( &self, serializer: &mut dyn Serializer, ) -> Result<(), ErrorImpl>
§impl<T> ToStringFallible for Twhere
T: Display,
impl<T> ToStringFallible for Twhere
T: Display,
§fn try_to_string(&self) -> Result<String, TryReserveError>
fn try_to_string(&self) -> Result<String, TryReserveError>
ToString::to_string, but without panic on OOM.