Struct Publisher 

pub struct Publisher<P> { /* private fields */ }

Implementations

impl<P: Declared> Publisher<P>

pub fn supervisor(&self) -> &Supervisor

pub async fn publish_on<S: StreamSpec>( &self, row: &S::Row, ) -> Result<(), PublishError>

where S::Row: Message,

pub async fn publish_on_context<S: StreamSpec>( &self, row: &S::Row, context: Option<&str>, ) -> Result<(), PublishError>

where S::Row: Message,

pub fn batch<S: StreamSpec>(&self) -> Batch<S>

pub async fn publish_batch_on<S: StreamSpec>( &self, batch: &Batch<S>, ) -> Result<(), PublishError>

pub async fn publish_batch_on_context<S: StreamSpec>( &self, batch: &Batch<S>, context: Option<&str>, ) -> Result<(), PublishError>

Trait Implementations

impl<P> Clone for Publisher<P>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<P: Declared> ObserverHost for Publisher<P>

fn bind(_: Arc<ExecutionContext>, supervisor: Supervisor) -> Self

impl<V: StreamSpec<Row = V> + Described + Message, P: Declared> ObserverPublisher<V> for Publisher<P>

const STREAM: Option<Entry>

type Error = PublishError

async fn publish( &self, _: &ObserverContext<'_, Self>, value: V, ) -> Result<(), PublishError>

impl<S: StreamSpec, P: Declared> ObserverStreamPublisher<S> for Publisher<P>

where S::Row: Message,

type Error = PublishError

async fn publish_on( &self, _: &ObserverContext<'_, Self>, row: &S::Row, ) -> Result<(), PublishError>