Trait ObserverPublisher 

pub trait ObserverPublisher<V: Send>:
    Send
    + Sync
    + Sized {
    type Error: Error + From<PublicationError> + Send + Sync + 'static;

    const STREAM: Option<Entry> = None;

    // Required method
    fn publish(
        &self,
        context: &ObserverContext<'_, Self>,
        value: V,
    ) -> impl Future<Output = Result<(), Self::Error>> + Send;
}

Provided Associated Constants

const STREAM: Option<Entry> = None

Required Associated Types

type Error: Error + From<PublicationError> + Send + Sync + 'static

Required Methods

fn publish( &self, context: &ObserverContext<'_, Self>, value: V, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

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

const STREAM: Option<Entry>

type Error = PublishError