fn buffer_noop() {
    let sink = Vec::new().buffer(0);
    let sink = block_on(sink.send(0)).unwrap();
    let sink = block_on(sink.send(1)).unwrap();
    assert_eq!(sink.get_ref(), &[0, 1]);

    let sink = Vec::new().buffer(1);
    let sink = block_on(sink.send(0)).unwrap();
    let sink = block_on(sink.send(1)).unwrap();
    assert_eq!(sink.get_ref(), &[0, 1]);
}
// test that a buffer is a no-nop around a sink that always accepts sends
test that a buffer is a no-nop around a sink that always accepts sends
test that a buffer is a no - nop around a sink that always accepts sends
fn buffer_noop() {
    let sink = Vec::new().buffer(0);
    let sink = block_on(sink.send(0)).unwrap();
    let sink = block_on(sink.send(1)).unwrap();
    assert_eq!(sink.get_ref(), &[0, 1]);
    let sink = Vec::new().buffer(1);
    let sink = block_on(sink.send(0)).unwrap();
    let sink = block_on(sink.send(1)).unwrap();
    assert_eq!(sink.get_ref(), &[0, 1]);
}
fn buffer_noop ( ) { let sink = Vec :: new ( ) . buffer ( 0 ) ; let sink = block_on ( sink . send ( 0 ) ) . unwrap ( ) ; let sink = block_on ( sink . send ( 1 ) ) . unwrap ( ) ; assert_eq ! ( sink get_ref ( ) [ 0 1 ] ) ; let sink = Vec :: new ( ) . buffer ( 1 ) ; let sink = block_on ( sink . send ( 0 ) ) . unwrap ( ) ; let sink = block_on ( sink . send ( 1 ) ) . unwrap ( ) ; assert_eq ! ( sink get_ref ( ) [ 0 1 ] ) ; }
test that a buffer is a no-nop around a sink that always accepts sends
test that a buffer is a no - nop around a sink that always accepts sends