// Checks whether the events read from `output` match supplied `expected` events.
Checks whether the events read from `output` match supplied `expected` events.
Checks whether the events read from ` output ` match supplied ` expected ` events .
async fn assert_events(output: UnboundedReceiver<InputEvent>, expected: Vec<InputEvent>) {
        // Spends a little while longer in the processing loop to ensure that all events have been
        // drained before we take the events out.  The wait is in fake time, so it does not
        // introduce nondeterminism into the tests.
        wait_for_duration(SLACK_DURATION).await;
        assert_eq!(
            remove_event_time(output.take(expected.len()).collect::<Vec<InputEvent>>().await),
            expected
        );
    }
async fn assert_events ( output : UnboundedReceiver < InputEvent > , expected : Vec < InputEvent > ) { // Spends a little while longer in the processing loop to ensure that all events have been // drained before we take the events out.  The wait is in fake time, so it does not // introduce nondeterminism into the tests. wait_for_duration ( SLACK_DURATION ) . await ; assert_eq ! ( remove_event_time ( output take ( expected len ( ) ) collect Vec InputEvent ( ) await ) expected ) ; }
Checks whether the events read from `output` match supplied `expected` events.
Checks whether the events read from ` output ` match supplied ` expected ` events .
output
UnboundedReceiver<InputEvent>
expected
Vec<InputEvent>