Trait pulsar::PulsarExecutor

pub trait PulsarExecutor: Executor<Box<dyn Future<Item = (), Error = ()> + Send + 'static>> + Send + Sync + 'static { }

Implementors

impl<T: Executor<Box<dyn Future<Item = (), Error = ()> + Send + 'static>> + Send + Sync + 'static> PulsarExecutor for T

Loading content...