@Test public void testContinuouslyWithLargeInput() throws Exception { DirectByteBufInStringOutPayload payload = new DirectByteBufInStringOutPayload(); StringBuilder randomStr = new StringBuilder(); payload.startInput(); for(int i = 0; i < 10; i ++) { String delta = randomString(1024); ByteBuf byteBuf = directByteBuf(delta.length()); byteBuf.writeBytes(delta.getBytes()); randomStr.append(delta); payload.in(byteBuf); byteBuf.release(); } payload.endInput(); Assert.assertEquals(randomStr.toString(), payload.toString()); sleep(5000); }
@Override public String toString() { return result; }
DirectByteBufInStringOutPayload extends AbstractInOutPayload { @Override public String toString() { return result; } }
DirectByteBufInStringOutPayload extends AbstractInOutPayload { @Override public String toString() { return result; }  }
DirectByteBufInStringOutPayload extends AbstractInOutPayload { @Override public String toString() { return result; }  @Override String toString(); }
DirectByteBufInStringOutPayload extends AbstractInOutPayload { @Override public String toString() { return result; }  @Override String toString(); static final Cumulator COMPOSITE_CUMULATOR; static final Cumulator MERGE_CUMULATOR; }