Struct PluginStream 

pub struct PluginStream { /* private fields */ }

Implementations

impl PluginStream

pub fn definition(&self) -> &Definition

pub fn query(&self, range: impl RangeBounds<Position>) -> Query<PublicationRow>

pub fn watch( &self, ) -> impl Stream<Item = Item<PublicationRow>> + Send + Unpin + use<>

pub fn watch_managed( &self, ) -> impl Stream<Item = Item<ManagedPublication>> + Send + Unpin + use<>

pub fn demand(&self) -> Demand

Trait Implementations

impl Clone for PluginStream

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.