Struct LocalStreamEngine 

pub struct LocalStreamEngine { /* private fields */ }

Local implementation of StreamEngine using per-subscriber channels and poll semantics.

Implementations

impl LocalStreamEngine

pub fn new() -> Self

Trait Implementations

impl Default for LocalStreamEngine

fn default() -> Self

Returns the “default value” for a type.

impl StreamEngine for LocalStreamEngine

type Handle = usize

fn publish(&self, atom: &Atom) -> Result<()>

fn subscribe( &self, world: &WorldKey, filter: AtomFilter, ) -> Result<Self::Handle>

fn poll(&self, handle: &Self::Handle) -> Result<Option<Atom>>

fn stop(&self, handle: Self::Handle) -> Result<()>