@Override
    public void collect(OUT outputRecord) {
        output.collect(reuse.replace(outputRecord));
    }
@Test
    void testCollect() {
        List<StreamElement> list = new ArrayList<>();
        CollectorOutput<Integer> collectorOutput = new CollectorOutput<>(list);
        OutputCollector<Integer> collector = new OutputCollector<>(collectorOutput);
        collector.collect(1);
        collector.collect(2);
        assertThat(list).containsExactly(new StreamRecord<>(1), new StreamRecord<>(2));
    }