Struct ObserverManager

pub struct ObserverManager<T: NotificationClient, S: ObserverState> {
    rx: T::Channel,
    client: T,
    observer_states: S,
}

ObserverManager is used to update data based on notification from meta. Call start to spawn a new asynchronous task We can write the notification logic by implementing ObserverNodeImpl.

Fields

rx: T::Channel

client: T

observer_states: S

Implementations

impl<S: ObserverState> ObserverManager<RpcNotificationClient, S>

pub async fn new_with_meta_client( meta_client: MetaClient, observer_states: S, ) -> Self

impl<T, S> ObserverManager<T, S>

where T: NotificationClient, S: ObserverState,

pub async fn new(client: T, observer_states: S) -> Self

async fn wait_init_notification(&mut self) -> Result<(), ObserverError>

pub async fn start(self) -> JoinHandle<()>

start is used to spawn a new asynchronous task which receives meta’s notification and call the handle_initialization_notification and handle_notification to update node data.

async fn re_subscribe(&mut self)

re_subscribe is used to re-subscribe to the meta’s notification.