Struct ObserverContext 

pub struct ObserverContext<'a, R, H = Supervisor> { /* private fields */ }

Implementations

impl<R, H> ObserverContext<'_, R, H>

pub fn observer_id(&self) -> &'static str

pub fn activation_id(&self) -> ActivationId

pub fn resources(&self) -> &R

pub fn tick(&self) -> &Tick

pub fn host(&self) -> &H

pub fn extension<T: Send + Sync + 'static>(&self) -> Option<&T>

impl<R> ObserverContext<'_, R, Supervisor>

pub fn supervisor(&self) -> &Supervisor

impl<R: Sync, H> ObserverContext<'_, R, H>

pub async fn publish<V: Send>(&self, value: V) -> Result<(), H::Error>

where H: ObserverPublisher<R, V>,

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

where S::Row: Sync, H: ObserverStreamPublisher<R, S>,

pub async fn call<C>( &self, request: H::Request, ) -> Result<H::Response, H::Error>

where H: ObserverCaller<R, C>,