pub trait StreamConsumer<A: Application>: Send + 'static {
// Required methods
fn resume(&self) -> Cursor;
fn drain(&mut self, batch: Batch<A>) -> impl Future<Output = Cursor> + Send;
// Provided methods
fn selections(&self) -> Vec<Definition> { ... }
fn flush(&mut self) -> impl Future<Output = ()> + Send { ... }
}Required Methods§
fn resume(&self) -> Cursor
fn drain(&mut self, batch: Batch<A>) -> impl Future<Output = Cursor> + Send
Provided Methods§
fn selections(&self) -> Vec<Definition>
fn flush(&mut self) -> impl Future<Output = ()> + Send
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".