@Test public void testBatchFlush() { setupForBatch(2); testBatch(2, 2); }
public static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries) { return new BatchFlush(durationBoundaries, batchSize); }
FlushStrategies { public static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries) { return new BatchFlush(durationBoundaries, batchSize); } }
FlushStrategies { public static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries) { return new BatchFlush(durationBoundaries, batchSize); } private  FlushStrategies(); }
FlushStrategies { public static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries) { return new BatchFlush(durationBoundaries, batchSize); } private  FlushStrategies(); static FlushStrategy defaultFlushStrategy(); static FlushStrategy flushOnEach(); static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries); static FlushStrategy flushWith(Publisher<?> flushBoundaries); static FlushStrategy flushOnEnd(); }
FlushStrategies { public static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries) { return new BatchFlush(durationBoundaries, batchSize); } private  FlushStrategies(); static FlushStrategy defaultFlushStrategy(); static FlushStrategy flushOnEach(); static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries); static FlushStrategy flushWith(Publisher<?> flushBoundaries); static FlushStrategy flushOnEnd();  }