RecordCollector implements RecordProcessor<P, P> { @Override public Record<P> processRecord(final Record<P> record) { records.add(record); return record; }  @Override Record<P> processRecord(final Record<P> record); List<Record<P>> getRecords();  }
@Test public void testProcessRecord() { assertThat(recordCollector.processRecord(record1)).isEqualTo(record1); }