Struct medea_jason::utils::component::WatchersSpawner

pub struct WatchersSpawner<S, O> { /* private fields */ }

Spawner for the Component’s watchers.

Implementations

impl<S: 'static, O: 'static> WatchersSpawner<S, O>

pub fn spawn<R, V, F, H>(&mut self, rx: R, handle: F)where R: Stream<Item = V> + Unpin + 'static, F: Fn(Rc<O>, Rc<S>, V) -> H + 'static, H: Future + 'static, <H as Future>::Output: IntoResult,

Spawns watchers for the provided [Stream].

If watcher returns an error then this error will be printed to the error log.

You can stop all listeners tasks spawned by this function by Dropping the Component.

pub fn spawn_sync<R, V, F, Obj, St, H>(&mut self, rx: R, handle: F)where R: Stream<Item = V> + Unpin + 'static, F: Fn(&Obj, &St, V) -> H + 'static, Rc<O>: Borrow<Obj>, Rc<S>: Borrow<St>, H: IntoResult + 'static,

Spawns synchronous watchers for the provided [Stream].

If watcher returns an error then this error will be printed to the error log.

You can stop all listeners tasks spawned by this function by Dropping the Component.

Trait Implementations

impl<S: Debug, O: Debug> Debug for WatchersSpawner<S, O>

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

Formats the value using the given formatter.