public class ParallelCollectTest
extends java.lang.Object
构造器和说明 |
---|
ParallelCollectTest() |
限定符和类型 | 方法和说明 |
---|---|
void |
collect() |
void |
failCombination() |
void |
failInitial() |
void |
parallelism() |
void |
scanOperator() |
void |
scanSubscriberCancelledScenario() |
void |
scanSubscriberTerminatedScenario() |
void |
testPrefetch() |
@Test public void collect()
@Test public void failInitial()
@Test public void failCombination()
@Test public void testPrefetch()
@Test public void parallelism()
@Test public void scanOperator()
@Test public void scanSubscriberTerminatedScenario()
@Test public void scanSubscriberCancelledScenario()