Struct System

pub struct System { /* private fields */ }

A manager for a per-thread distributed async runtime.

Implementations

impl System

pub fn new() -> SystemRunner

Create a new system.

Panics

Panics if underlying Tokio runtime can not be created.

pub fn with_tokio_rt<F>(runtime_factory: F) -> SystemRunner

where F: FnOnce() -> Runtime,

Create a new System using the Tokio Runtime returned from a closure.

impl System

pub fn current() -> System

Get current running system.

Panics

Panics if no system is registered on the current thread.

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.

pub fn arbiter(&self) -> &ArbiterHandle

Get handle to a the System’s initial Arbiter.

pub fn is_registered() -> bool

Check if there is a System registered on the current thread.

pub fn id(&self) -> usize

Numeric system identifier.

Useful when using multiple Systems.

pub fn stop(&self)

Stop the system (with code 0).

pub fn stop_with_code(&self, code: i32)

Stop the system with a given exit code.

Trait Implementations

impl Clone for System

fn clone(&self) -> System

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for System

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.