pub trait ConcurrentStore: for<'c> Store<Connection<'c> = Self::ConcurrentConnection<'c>> {
type ConcurrentConnection<'c>: ConcurrentConnection
where Self: 'c;
const DELIMITER: &'static str = "@";
}Expand description
Extension of Store for stores that support concurrent pipeline operations, including
task-based pipeline watermark tracking.
Provided Associated Constants§
Required Associated Types§
type ConcurrentConnection<'c>: ConcurrentConnection where Self: 'c
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.