Struct OneshotBridge

pub struct OneshotBridge<N>
where
    N: Oneshot + 'static,
{ /* private fields */ }

A connection manager for components interaction with oneshot workers.

Implementations

impl<N> OneshotBridge<N>

where N: Oneshot + 'static,

pub fn fork(&self) -> OneshotBridge<N>

Forks the bridge.

This method creates a new bridge that can be used to execute tasks on the same worker instance.

pub async fn run( &mut self, input: <N as Oneshot>::Input, ) -> <N as Future>::Output

Run the the current oneshot worker once in the current worker instance.

Trait Implementations

impl<N> Debug for OneshotBridge<N>

where N: Debug + Oneshot + 'static, <N as Future>::Output: Debug,

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

Formats the value using the given formatter.