Skip to main content

check_large_stream_completes

mnesis_store_testing::sequence

Function check_large_stream_completes 

Source 
pub async fn check_large_stream_completes<S, C, F, Fut>(factory: &F)
where
    S: RawEventStore + WakeSource,
    C: Send,
    F: Fn() -> Fut + Send + Sync,
    Fut: Future<Output = (S, C)> + Send,
Expand description

A stream larger than any internal batch/refill size (1500 events) drains completely with no gap or duplicate across the seams.