pub struct System { /* private fields */ }
Expand description
A manager for a per-thread distributed async runtime.
Implementations§
source§impl System
impl System
sourcepub fn new() -> SystemRunner
pub fn new() -> SystemRunner
sourcepub fn with_tokio_rt<F>(runtime_factory: F) -> SystemRunnerwhere
F: Fn() -> Runtime,
pub fn with_tokio_rt<F>(runtime_factory: F) -> SystemRunnerwhere
F: Fn() -> Runtime,
Create a new System using the Tokio Runtime returned from a closure.
source§impl System
impl System
sourcepub fn try_current() -> Option<System>
pub fn try_current() -> Option<System>
Try to get current running system.
Returns None
if no System has been started.
Unlike current
, this never panics.
sourcepub fn arbiter(&self) -> &ArbiterHandle
pub fn arbiter(&self) -> &ArbiterHandle
Get handle to a the System’s initial Arbiter.
sourcepub fn is_registered() -> bool
pub fn is_registered() -> bool
Check if there is a System registered on the current thread.
sourcepub fn stop_with_code(&self, code: i32)
pub fn stop_with_code(&self, code: i32)
Stop the system with a given exit code.