@Test public void testScaleOut() throws Exception { DirectByteBufInStringOutPayload payload = new DirectByteBufInStringOutPayload(); String randomStr = randomString(); ByteBuf byteBuf = directByteBuf(randomStr.length()); randomStr += randomString(2<<11); byteBuf.writeBytes(randomStr.getBytes()); payload.startInput(); payload.in(byteBuf); payload.endInput(); Assert.assertEquals(randomStr, payload.toString()); }
@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; }