Trait ObserverStreamPublisher 

pub trait ObserverStreamPublisher<S: StreamSpec>:
    Send
    + Sync
    + Sized
where
    S::Row: Sync,
{
    type Error: Error + From<PublicationError> + Send + Sync + 'static;

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

Required Associated Types

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

Required Methods

fn publish_on( &self, context: &ObserverContext<'_, Self>, row: &S::Row, ) -> 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<S: StreamSpec, P: Declared> ObserverStreamPublisher<S> for Publisher<P>

where S::Row: Message,

type Error = PublishError