pub struct PortAddr { /* private fields */ }Expand description
A port identifier paired with a network location.
Implementations§
Source§impl PortAddr
impl PortAddr
Sourcepub fn actor_addr(&self) -> ActorAddr
pub fn actor_addr(&self) -> ActorAddr
Reconstruct the parent ActorAddr (with location preserved).
Sourcepub fn actor_ref(&self) -> ActorAddr
pub fn actor_ref(&self) -> ActorAddr
Reconstruct the parent ActorAddr (with location preserved).
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.
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 with explicit headers.
Sourcepub fn split(
&self,
cx: &impl Actor,
reducer_spec: Option<ReducerSpec>,
reducer_mode: ReducerMode,
return_undeliverable: bool,
) -> Result<PortAddr>
pub fn split( &self, cx: &impl Actor, reducer_spec: Option<ReducerSpec>, reducer_mode: ReducerMode, return_undeliverable: bool, ) -> Result<PortAddr>
Split this port through a local proxy, possibly reducing messages.
Trait Implementations§
Source§impl<'de> Deserialize<'de> for PortAddr
impl<'de> Deserialize<'de> for PortAddr
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>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Named for PortAddr
impl Named for PortAddr
Source§fn typename() -> &'static str
fn typename() -> &'static str
The globally unique type name for the type.
This should typically be the fully qualified Rust name of the type.
Source§fn typehash() -> u64
fn typehash() -> u64
A globally unique hash for this type.
TODO: actually enforce perfect hashing
Source§fn typeid() -> TypeId
fn typeid() -> TypeId
The TypeId for this type. TypeIds are unique only within a binary,
and should not be used for global identification.
Source§fn port() -> u64
fn port() -> u64
The globally unique port for this type. Typed ports are in the range
of 1<<63..1<<64-1.
Source§impl Ord for PortAddr
impl Ord for PortAddr
Source§impl PartialOrd for PortAddr
impl PartialOrd for PortAddr
impl Eq for PortAddr
Auto Trait Implementations§
impl Freeze for PortAddr
impl RefUnwindSafe for PortAddr
impl Send for PortAddr
impl Sync for PortAddr
impl Unpin for PortAddr
impl UnsafeUnpin for PortAddr
impl UnwindSafe for PortAddr
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
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
Checks if this value is equivalent to the given key. Read more
§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
Checks if this value is equivalent to the given key. Read more
§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
Compare self to
key and return true if they are equal.§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
Checks if this value is equivalent to the given key. Read more
§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>
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 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].