@Override
    public T next() {
        return buffer.poll();
    }
@Test
    public void testEmptyCollectorReturnsNull() {
        BufferingCollector<Integer> collector = new BufferingCollector<>();
        Assert.assertNull("Empty collector did not return null", collector.next());
    }