Trait binlog::SubscribeableStore

pub trait SubscribeableStore: Store {
    type Subscription: Iterator<Item = Result<Entry, Error>>;
    fn subscribe(&self, name: Atom) -> Result<Self::Subscription, Error>;
}

Associated Types

type Subscription: Iterator<Item = Result<Entry, Error>>

Required methods

fn subscribe(&self, name: Atom) -> Result<Self::Subscription, Error>

Implementors

impl SubscribeableStore for MemoryStore

type Subscription = MemoryStreamIterator