pub struct MaterializingAnalyzer { /* private fields */ }Implementations§
Source§impl MaterializingAnalyzer
impl MaterializingAnalyzer
pub fn with_view(view: SharedMaterializedView) -> Self
pub fn add_view_sink(self, sink: Box<dyn ViewSink>) -> Self
Trait Implementations§
Source§impl Analyzer for MaterializingAnalyzer
impl Analyzer for MaterializingAnalyzer
Source§fn process<'life0, 'async_trait>(
&'life0 mut self,
stream: EventStream,
) -> Pin<Box<dyn Future<Output = Result<EventStream, AnalyzerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn process<'life0, 'async_trait>(
&'life0 mut self,
stream: EventStream,
) -> Pin<Box<dyn Future<Output = Result<EventStream, AnalyzerError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Process an event stream and return a processed stream
Auto Trait Implementations§
impl Freeze for MaterializingAnalyzer
impl RefUnwindSafe for MaterializingAnalyzer
impl Send for MaterializingAnalyzer
impl Sync for MaterializingAnalyzer
impl Unpin for MaterializingAnalyzer
impl UnsafeUnpin for MaterializingAnalyzer
impl UnwindSafe for MaterializingAnalyzer
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more