def test_batched_buffer_stream_through(batch_size):
    """Feed a 0:99 sequence through a BatchedNoopShufflingBuffer. Check that the order has not changed."""
    expected = list(range(100))
    actual = _feed_a_sequence_through_the_queue(BatchedNoopShufflingBuffer(batch_size), expected)
    assert expected == actual
Feed a 0:99 sequence through a BatchedNoopShufflingBuffer. Check that the order has not changed.
petastorm/tests/test_shuffling_buffer.py