public class MonoReduceSeedTest extends ReduceOperatorTest<java.lang.String,java.lang.String>
ReduceOperatorTest.Scenario<I,O>
构造器和说明 |
---|
MonoReduceSeedTest() |
限定符和类型 | 方法和说明 |
---|---|
void |
accumulatorNull() |
void |
accumulatorReturnsNull() |
void |
accumulatorThrows() |
void |
discardAccumulatedOnCancel() |
void |
discardOnError() |
void |
discardOnNextAfterCancel() |
void |
noRetainValueOnCancel() |
void |
noRetainValueOnError() |
void |
normal() |
void |
normalBackpressured() |
void |
onNextAndCancelRace() |
void |
scanOperator() |
void |
scanSubscriberCancelledScenario() |
void |
scanSubscriberTerminatedScenario() |
void |
sourceNull() |
void |
supplierNull() |
void |
supplierReturnsNull() |
void |
supplierThrows() |
scenario
@Test public void sourceNull()
@Test public void supplierNull()
@Test public void accumulatorNull()
@Test public void normal()
@Test public void normalBackpressured()
@Test public void supplierThrows()
@Test public void accumulatorThrows()
@Test public void supplierReturnsNull()
@Test public void accumulatorReturnsNull()
@Test public void onNextAndCancelRace()
@Test public void discardAccumulatedOnCancel()
@Test public void discardOnNextAfterCancel()
@Test public void discardOnError()
@Test public void noRetainValueOnCancel()
@Test public void noRetainValueOnError()
@Test public void scanOperator()
@Test public void scanSubscriberTerminatedScenario()
@Test public void scanSubscriberCancelledScenario()