Struct ObserverContext 

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

Implementations

impl<H> ObserverContext<'_, H>

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

pub fn activation_id(&self) -> ActivationId

pub fn resource<T: Send + Sync + 'static>( &self, ) -> Result<Arc<T>, ResourceError>

pub fn tick(&self) -> &Tick

pub fn host(&self) -> &H

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

impl ObserverContext<'_, Supervisor>

pub fn supervisor(&self) -> &Supervisor

impl<H> ObserverContext<'_, H>

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

where H: ObserverPublisher<V>,

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

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

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

where H: ObserverCaller<C>,