@Test public void testEndRecord() throws Exception { collapser.endRecord(); Mockito.verify(mockedReceiver).endRecord(); }
@Override public void endRecord() { flushValues(); getReceiver().endRecord(); }
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void endRecord() { flushValues(); getReceiver().endRecord(); } }
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void endRecord() { flushValues(); getReceiver().endRecord(); }  }
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void endRecord() { flushValues(); getReceiver().endRecord(); }  @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); }
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void endRecord() { flushValues(); getReceiver().endRecord(); }  @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; }