@Test public void testStartRecord() throws Exception { final String expected = "foobar"; collapser.startRecord(expected); Mockito.verify(mockedReceiver).startRecord(expected); }
@Override public void startRecord(final String identifier) { valueMap.clear(); getReceiver().startRecord(identifier); }
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void startRecord(final String identifier) { valueMap.clear(); getReceiver().startRecord(identifier); } }
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void startRecord(final String identifier) { valueMap.clear(); getReceiver().startRecord(identifier); }  }
StreamJsonCollapser extends DefaultStreamPipe<StreamReceiver> { @Override public void startRecord(final String identifier) { valueMap.clear(); getReceiver().startRecord(identifier); }  @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 startRecord(final String identifier) { valueMap.clear(); getReceiver().startRecord(identifier); }  @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; }