Trait StreamEngine 

pub trait StreamEngine {
    type Handle;

    // Required methods
    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<()>;
}

Stream processing interface.

Required Associated Types

type Handle

Required Methods

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<()>

Implementors