### Question:
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void endEntity() { flushValues(); getReceiver().endEntity(); }  @Override void startRecord(final String identifier); @Override void endRecord(); @Override void startEntity(final String name); @Override void endEntity(); @Override void literal(final String name, final String value); static final String ARRAY_MARKER; }### Answer:
@Test public void testEndEntity() throws Exception { collapser.endRecord(); Mockito.verify(mockedReceiver).endRecord(); }