Trait reactor_rs::schedulers::Scheduler

pub trait Scheduler {
    type Item;
    type Error;
    fn schedule<P, S>(&self, publisher: P, subscriber: S)
    where
        Self: Sized,
        P: 'static + Send + Sized + Publisher<Item = Self::Item, Error = Self::Error>,
        S: 'static + Send + Sized + Subscriber<Item = Self::Item, Error = Self::Error>;
}

Associated Types

type Item

type Error

Loading content...

Required methods

fn schedule<P, S>(&self, publisher: P, subscriber: S) where
    Self: Sized,
    P: 'static + Send + Sized + Publisher<Item = Self::Item, Error = Self::Error>,
    S: 'static + Send + Sized + Subscriber<Item = Self::Item, Error = Self::Error>, 

Loading content...

Implementors

Loading content...