Trait Manager 

pub trait Manager<T> {
    type Protocol: Protocol + Send + 'static;
    type Args: Clone + Send + 'static;
    type Message: Clone + Send + 'static;
    type Event: Clone + Debug + Send + 'static;
    type Error: StdError + Send + Sync + 'static;

    // Required methods
    fn from_args(args: Self::Args) -> Self;
    fn session(
        &mut self,
        session_id: u64,
        config: &SessionConfig<T>,
    ) -> impl Future<Output = Self::Protocol>;
    fn session_handle(
        &self,
        session_id: u64,
    ) -> impl Future<Output = Option<Pin<Box<dyn Sink<ToSync<Self::Message>, Error = Self::Error>>>>>;
    fn subscribe(
        &mut self,
    ) -> impl Stream<Item = FromSync<Self::Event>> + Send + Unpin + 'static;
}

Interface for managing sync sessions and consuming events they emit.

Required Associated Types

type Protocol: Protocol + Send + 'static

type Args: Clone + Send + 'static

type Message: Clone + Send + 'static

type Event: Clone + Debug + Send + 'static

type Error: StdError + Send + Sync + 'static

Required Methods

fn from_args(args: Self::Args) -> Self

fn session( &mut self, session_id: u64, config: &SessionConfig<T>, ) -> impl Future<Output = Self::Protocol>

Instantiate a new sync session.

fn session_handle( &self, session_id: u64, ) -> impl Future<Output = Option<Pin<Box<dyn Sink<ToSync<Self::Message>, Error = Self::Error>>>>>

Retrieve a send handle to an already existing sync session.

fn subscribe( &mut self, ) -> impl Stream<Item = FromSync<Self::Event>> + Send + Unpin + 'static

Subscribe to the manager event stream.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<T, S, M, L, E> Manager<T> for TopicSyncManager<T, S, M, L, E>

where T: Clone + Debug + Eq + StdHash + Serialize + for<'a> Deserialize<'a> + Send + 'static, S: LogStore<L, E> + OperationStore<L, E> + Send + 'static, M: TopicMap<T, Logs<L>> + Send + 'static, L: LogId + for<'de> Deserialize<'de> + Serialize + Send + 'static, E: Extensions + Send + 'static,

type Protocol = TopicLogSync<T, S, M, L, E>

type Args = TopicSyncManagerArgs<S, M>

type Event = TopicLogSyncEvent<E>

type Message = Operation<E>

type Error = TopicSyncManagerError