Struct Agent 

pub struct Agent<P>
where
    P: Debug + Send + Sync + 'static,
{ /* private fields */ }

An Agent with the basic configuration decisions fixed, but not running

Implementations

impl<P> Agent<P>

where P: Debug + Send + Sync + 'static,

pub const fn new(properties: P) -> UnconfiguredAgent<P>

Builder

pub const fn liveliness(&mut self, activate: bool)

Activate sending liveliness information

pub fn liveliness_subscriber( &self, ) -> LivelinessSubscriberBuilder<P, NoCallback, Storage<Box<dyn LivelinessSubscriber>>>

Get a LivelinessSubscriberBuilder, the builder for a LivelinessSubscriber.

pub fn liveliness_subscriber_for( &self, session_id: impl Into<String>, ) -> LivelinessSubscriberBuilder<P, NoCallback, Storage<Box<dyn LivelinessSubscriber>>>

Get a LivelinessSubscriberBuilder, the builder for a LivelinessSubscriber.

pub fn observable( &self, ) -> ObservableBuilder<P, NoSelector, NoCallback, NoCallback, NoCallback, Storage<Box<dyn Responder>>>

Get an ObservableBuilder, the builder for an Observable.

pub fn observable_for( &self, session_id: impl Into<String>, ) -> ObservableBuilder<P, NoSelector, NoCallback, NoCallback, NoCallback, Storage<Box<dyn Responder>>>

Get an ObservableBuilder, the builder for an Observable.

pub fn observer( &self, ) -> ObserverBuilder<P, NoSelector, NoCallback, NoCallback, Storage<Box<dyn Observer>>>

Get an ObserverBuilder, the builder for an Observer.

pub fn observer_for( &self, session_id: impl Into<String>, ) -> ObserverBuilder<P, NoSelector, NoCallback, NoCallback, Storage<Box<dyn Observer>>>

Get an ObserverBuilder, the builder for an Observer.

pub fn publisher( &self, ) -> PublisherBuilder<P, NoSelector, Storage<Box<dyn Publisher>>>

Get a PublisherBuilder, the builder for a sPublisher.

pub fn publisher_for( &self, session_id: impl Into<String>, ) -> PublisherBuilder<P, NoSelector, Storage<Box<dyn Publisher>>>

Get a PublisherBuilder, the builder for a sPublisher.

pub fn querier( &self, ) -> QuerierBuilder<P, NoSelector, NoCallback, Storage<Box<dyn Querier>>>

Get a QuerierBuilder, the builder for a Querier.

pub fn querier_for( &self, session_id: impl Into<String>, ) -> QuerierBuilder<P, NoSelector, NoCallback, Storage<Box<dyn Querier>>>

Get a QuerierBuilder, the builder for a Querier.

pub fn queryable( &self, ) -> QueryableBuilder<P, NoSelector, NoCallback, Storage<Box<dyn Responder>>>

Get a QueryableBuilder, the builder for a Queryable.

pub fn queryable_for( &self, session_id: impl Into<String>, ) -> QueryableBuilder<P, NoSelector, NoCallback, Storage<Box<dyn Responder>>>

Get a QueryableBuilder, the builder for a Queryable.

pub fn subscriber( &self, ) -> SubscriberBuilder<P, NoSelector, NoCallback, Storage<Box<dyn Responder>>>

Get a SubscriberBuilder, the builder for a Subscriber.

pub fn subscriber_for( &self, session_id: impl Into<String>, ) -> SubscriberBuilder<P, NoSelector, NoCallback, Storage<Box<dyn Responder>>>

Get a SubscriberBuilder, the builder for a Subscriber.

pub fn timer( &self, ) -> TimerBuilder<P, NoSelector, NoInterval, NoCallback, Storage<Timer<P>>>

Get a TimerBuilder, the builder for a Timer.

pub async fn start(self) -> Result<Self>

Start the agent.

The agent can be stopped properly using ctrl-c

Errors

Panics

Trait Implementations

impl<P> Debug for Agent<P>

where P: Debug + Send + Sync + 'static,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.