@Test public void testFlushWithWriteCancelCancelsSource() { setupFor(flushWith(durationSource)); durationSource.onSubscribe(subscription); listener.writeCancelled(); assertTrue(subscription.isCancelled()); }
public static FlushStrategy flushWith(Publisher<?> flushBoundaries) { return batchFlush(MAX_VALUE, flushBoundaries); }
FlushStrategies { public static FlushStrategy flushWith(Publisher<?> flushBoundaries) { return batchFlush(MAX_VALUE, flushBoundaries); } }
FlushStrategies { public static FlushStrategy flushWith(Publisher<?> flushBoundaries) { return batchFlush(MAX_VALUE, flushBoundaries); } private  FlushStrategies(); }
FlushStrategies { public static FlushStrategy flushWith(Publisher<?> flushBoundaries) { return batchFlush(MAX_VALUE, flushBoundaries); } 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 flushWith(Publisher<?> flushBoundaries) { return batchFlush(MAX_VALUE, flushBoundaries); } private  FlushStrategies(); static FlushStrategy defaultFlushStrategy(); static FlushStrategy flushOnEach(); static FlushStrategy batchFlush(int batchSize, Publisher<?> durationBoundaries); static FlushStrategy flushWith(Publisher<?> flushBoundaries); static FlushStrategy flushOnEnd();  }