Struct Options

pub struct Options { /* private fields */ }

By default, RPC frame and notification handlers are launched in background which allows non-blocking event processing, however events can be processed in random order

RPC options allow to launch handlers in blocking mode. In this case handlers must process events as fast as possible (e.g. send them to processing channels) and avoid using any RPC client functions from inside.

WARNING: when handling frames in blocking mode, it is forbidden to use the current RPC client directly or with any kind of bounded channels, otherwise the RPC client may get stuck!

See https://busrt.readthedocs.io/en/latest/rpc_blocking.html

Implementations

impl Options

pub fn new() -> Self

pub fn blocking_notifications(self) -> Self

pub fn blocking_frames(self) -> Self

pub fn with_task_pool(self, pool: Pool) -> Self

See https://crates.io/crates/tokio-task-pool

Trait Implementations

impl Clone for Options

fn clone(&self) -> Options

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Options

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

Formats the value using the given formatter.

impl Default for Options

fn default() -> Options

Returns the “default value” for a type.