fn init_write_buffer(n_sequencers: u32) -> MockBufferForWriting {
        let time = iox_time::MockProvider::new(iox_time::Time::from_timestamp_millis(668563200000));
        MockBufferForWriting::new(
            MockBufferSharedState::empty_with_n_sequencers(
                n_sequencers.try_into().expect("cannot have 0 sequencers"),
            ),
            None,
            Arc::new(time),
        )
        .expect("failed to init mock write buffer")
    }
// Init a mock write buffer with the given number of sequencers.
Init a mock write buffer with the given number of sequencers.
Init a mock write buffer with the given number of sequencers .
fn init_write_buffer(n_sequencers: u32) -> MockBufferForWriting {
        let time = iox_time::MockProvider::new(iox_time::Time::from_timestamp_millis(668563200000));
        MockBufferForWriting::new(
            MockBufferSharedState::empty_with_n_sequencers(
                n_sequencers.try_into().expect("cannot have 0 sequencers"),
            ),
            None,
            Arc::new(time),
        )
        .expect("failed to init mock write buffer")
    }
fn init_write_buffer ( n_sequencers : u32 ) -> MockBufferForWriting { let time = iox_time :: MockProvider :: new ( iox_time :: Time :: from_timestamp_millis ( 668563200000 ) ) ; MockBufferForWriting :: new ( MockBufferSharedState :: empty_with_n_sequencers ( n_sequencers . try_into ( ) . expect ( " " ) , ) , None , Arc :: new ( time ) , ) . expect ( " " ) }
Init a mock write buffer with the given number of sequencers.
Init a mock write buffer with the given number of sequencers .
n_sequencers
u32
n_sequencers
u32