Struct Reactor 

pub struct Reactor { /* private fields */ }

Implementations

impl Reactor

pub fn new( pool_size: usize, events_capacity: usize, poll_timeout_ms: u64, ) -> Result<Self>

pub fn run(&self) -> Result<()>

pub fn get_shutdown_handle(&self) -> ShutdownHandle<'_>

pub fn dispatch_event(&self, event: Event) -> Result<()>

pub fn spawn_compute<F>(&self, task: F, priority: TaskPriority)

where F: FnOnce() + Send + 'static,

pub fn get_compute_metrics(&self) -> Arc<ComputePoolMetrics>

pub fn get_events(&self) -> Arc<RwLock<Events>>

Trait Implementations

impl Default for Reactor

fn default() -> Self

Returns the “default value” for a type.