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".

Implementors

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

where T: Clone + Debug + Eq + StdHash + Serialize + for<'a> Deserialize<'a> + Send + 'static, S: LogStore<Operation<E>, VerifyingKey, L, SeqNum, Hash> + TopicStore<T, VerifyingKey, L> + Clone + Send + 'static, L: LogId + Debug + Send + 'static, E: Extensions + Send + 'static,

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

type Args = S

type Event = TopicLogSyncEvent<E>

type Message = Operation<E>

type Error = TopicSyncManagerError