Skip to main content

PubSub

behavior_actors::discovery

Struct PubSub 

Source 
pub struct PubSub<A: Address, K, P, Route> { /* private fields */ }
Expand description

Deterministic keyed typed publish/subscribe behavior.

Topics are introduced by the first subscription and retained after their final unsubscription so an unknown topic remains distinguishable from a known empty one. Subscription is idempotent. Unsubscription from an unknown topic or absent membership is rejected atomically. Publication clones the value once per point-in-time subscriber in subscription order; an unknown or empty topic returns the original value in PubSubError::NoSubscribers. Initialization is empty, the behavior creates no actors, and it never terminates by policy. Membership retention and ordered snapshot delivery are Bombay policy; physical delivery remains a Communication capability. Cloning a publication can panic only if the application-provided Clone implementation panics, before any template state is changed.

Implementations§

Source§

impl<A, K, P, Route> PubSub<A, K, P, Route>
where A: Address, K: Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = P>> + PartialEq,

Source

pub const fn new() -> Self

Construct an empty keyed fabric.

Source

pub fn topics(&self) -> &[TopicMembership<K, Route>]

Borrow complete topic membership in introduction order.

Trait Implementations§

Source§

impl<A, K, P, Route> Behavior for PubSub<A, K, P, Route>
where A: Address, K: Clone + Eq, P: Clone, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = P>> + Clone + PartialEq, Route::Sends: SendsFor<User<A, PubSubMessage<K, P, Route>>>,

Source§

type Protocol = PubSub<A, K, P, Route>

Stable public communication identity owned by this actor template. Read more
Source§

type Event = User<A, <<PubSub<A, K, P, Route> as Behavior>::Protocol as Protocol>::Msg>

Source§

type Sends = <Route as DeliveryRoute>::Sends

Source§

type Ph = Never

Source§

type Error = PubSubError<K, P, Route>

Source§

type Birth = NoBirths

Source§

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> BehaviorActed<Self>

Fold exactly one event into explicit actions and the next behavior. Read more
Source§

fn init( &mut self, _turn: InitializationTurn, ) -> Result<Actions<<Self::Protocol as Protocol>::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>
where Self: Sized,

Produce initialization actions before the first event is accepted. Read more
Source§

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output
where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer. Read more
Source§

impl<A, K, P, Route> BehaviorBase for PubSub<A, K, P, Route>
where A: Address,

Source§

type Base = PubSub<A, K, P, Route>

Source§

fn base(&self) -> &Self

Source§

impl<A, K, P, Route> Default for PubSub<A, K, P, Route>
where A: Address, K: Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = P>> + PartialEq,

Source§

fn default() -> Self

Returns the “default value” for a type. Read more
Source§

impl<A: Address, K, P, Route> Protocol for PubSub<A, K, P, Route>

Source§

type Addr = A

Source§

type Msg = PubSubMessage<K, P, Route>

Auto Trait Implementations§

§

impl<A, K, P, Route> Freeze for PubSub<A, K, P, Route>

§

impl<A, K, P, Route> RefUnwindSafe for PubSub<A, K, P, Route>
where K: RefUnwindSafe, Route: RefUnwindSafe,

§

impl<A, K, P, Route> Send for PubSub<A, K, P, Route>
where K: Send, Route: Send,

§

impl<A, K, P, Route> Sync for PubSub<A, K, P, Route>
where K: Sync, Route: Sync,

§

impl<A, K, P, Route> Unpin for PubSub<A, K, P, Route>
where K: Unpin, Route: Unpin,

§

impl<A, K, P, Route> UnsafeUnpin for PubSub<A, K, P, Route>

§

impl<A, K, P, Route> UnwindSafe for PubSub<A, K, P, Route>
where K: UnwindSafe, Route: UnwindSafe,

Blanket Implementations§

Source§

impl<B> Activate for B
where B: Behavior,

Source§

fn initialize(self) -> Result<Initialized<Self>, Self::Error>

Consume this definition, perform its one initialization fold, and return the active behavior together with the ordered initialization effects. Read more
Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<B> BeginShutdownPhases for B
where B: Behavior, <<B as Behavior>::Birth as BirthMode>::Child: ChildOccurrenceProduct<AvailableChildren>,

Source§

type Output = ChildShutdownPhases<B, <<<B as Behavior>::Birth as BirthMode>::Child as ChildOccurrenceProduct<AvailableChildren>>::Product, NoPhases>

Source§

fn begin_shutdown_phases(self) -> <B as BeginShutdownPhases>::Output

Source§

impl<Node> BirthNodeAppend<Never> for Node
where Node: NonEmptyBirthNode,

Source§

type Output = Node

Closed child algebra containing the complete prefix followed by the complete appended tail.
Source§

fn append_prefix(self) -> <Node as BirthNodeAppend<Never>>::Output

Inject one child from the existing prefix without changing its structural occurrence.
Source§

fn append_tail(tail: Never) -> <Node as BirthNodeAppend<Never>>::Output

Inject one child from the appended tail after every prefix occurrence.
Source§

fn append_creations<A>( prefix: Creations<CreateChild<A, Self>>, tail: Creations<CreateChild<A, Tail>>, ) -> Creations<CreateChild<A, Self::Output>>
where A: Address,

Preserve and concatenate two ordered creation batches.
Source§

impl<Child, Tail> BirthNodeAppend<Tail> for Child
where Child: Behavior, Tail: NonEmptyBirthNode,

Source§

type Output = ChildChoice<Child, Tail>

Closed child algebra containing the complete prefix followed by the complete appended tail.
Source§

fn append_prefix(self) -> <Child as BirthNodeAppend<Tail>>::Output

Inject one child from the existing prefix without changing its structural occurrence.
Source§

fn append_tail(tail: Tail) -> <Child as BirthNodeAppend<Tail>>::Output

Inject one child from the appended tail after every prefix occurrence.
Source§

fn append_creations<A>( prefix: Creations<CreateChild<A, Self>>, tail: Creations<CreateChild<A, Tail>>, ) -> Creations<CreateChild<A, Self::Output>>
where A: Address,

Preserve and concatenate two ordered creation batches.
Source§

impl<B> BirthProtocols for B
where B: Behavior, <B as Behavior>::Birth: BirthModeProtocols,

Source§

type Protocols = BirthProtocol<<B as Behavior>::Protocol, <<B as Behavior>::Birth as BirthModeProtocols>::Protocols>

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<Node, Shape> ChildOccurrenceProduct<Shape> for Node
where Node: ChildOccurrenceProductAt<ChildHead, Shape>, Shape: ChildOccurrenceShape,

Source§

type Product = <Node as ChildOccurrenceProductAt<ChildHead, Shape>>::Product

Complete shape-owned representation of this closed birth node.
Source§

impl<A, Child, Host> DispatchBirth<A, Host> for Child
where A: Address, Child: CreateSelectedChild<A, ChildHead, Host>,

Source§

fn dispatch_birth( self, id: CreationId, route: <A as Address>::Nonce, kind: CreationKind, host: &mut Host, ) -> impl Future<Output = ItemSettlement<RoutedCreation<A, Child>, <Child as ChildCreationProduct<A, ChildHead>>::Result, CreationRejection, Never>> + Send

Select exactly one concrete child host while preserving creation data in every non-accepted settlement.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.