Skip to main content

Topic

behavior_actors::discovery

Struct Topic 

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

Insertion-ordered typed publication behavior.

Subscription and unsubscription are idempotent and preserve survivor order. Publication snapshots current membership and emits exactly one typed delivery per subscriber in that order. With no subscribers it returns TopicError::NoSubscribers containing the owned value; it never silently drops a publication. Initialization is empty and the topic never terminates itself. Membership order and empty-publication rejection are Bombay policy; endpoint resolution and delivery are Address/Communication capabilities. No method has a semantic panic condition.

Implementations§

Source§

impl<A: Address, P, Route> Topic<A, P, Route>

Source

pub const fn new() -> Self

Construct an empty topic definition.

Source

pub fn subscribers(&self) -> &[Route]

Borrow subscribers in publication order.

Trait Implementations§

Source§

impl<A, P, Route> Behavior for Topic<A, P, Route>
where A: Address, P: Clone, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = P>> + Clone + PartialEq, Route::Sends: SendsFor<User<A, TopicMessage<P, Route>>>,

Source§

type Protocol = Topic<A, P, Route>

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

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

Source§

type Sends = <Route as DeliveryRoute>::Sends

Source§

type Ph = Never

Source§

type Error = TopicError<P>

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, P, Route> BehaviorBase for Topic<A, P, Route>
where A: Address,

Source§

type Base = Topic<A, P, Route>

Source§

fn base(&self) -> &Self

Source§

impl<A: Address, P, Route> Default for Topic<A, P, Route>

Source§

fn default() -> Self

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

impl<A: Address, P, Route> Protocol for Topic<A, P, Route>

Source§

type Addr = A

Source§

type Msg = TopicMessage<P, Route>

Auto Trait Implementations§

§

impl<A, P, Route> Freeze for Topic<A, P, Route>

§

impl<A, P, Route> RefUnwindSafe for Topic<A, P, Route>
where Route: RefUnwindSafe,

§

impl<A, P, Route> Send for Topic<A, P, Route>
where Route: Send,

§

impl<A, P, Route> Sync for Topic<A, P, Route>
where Route: Sync,

§

impl<A, P, Route> Unpin for Topic<A, P, Route>
where Route: Unpin,

§

impl<A, P, Route> UnsafeUnpin for Topic<A, P, Route>

§

impl<A, P, Route> UnwindSafe for Topic<A, P, Route>
where 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.