### Question:
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void startEntity(final String name) { flushValues(); getReceiver().startEntity(name); }  @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 testStartEntity() throws Exception { final String expected = "foobar"; collapser.startEntity(expected); Mockito.verify(mockedReceiver).startEntity(expected); }