### Question:
RowSink extends NamedSink { @Override public void processRow(Row entries) { consumer.accept(entries); } RowSink();  RowSink(String name, Consumer<Row> consumer); @Override void processRow(Row entries);  }### Answer:
@Test public void process() { RowSink cut = new RowSink("*", r -> { assertThat(r, is(expected)); this.setTested(); }); cut.processRow(expected); assertTrue(tested); }