public class FluxUsingTest extends FluxOperatorTest<java.lang.String,java.lang.String>
FluxOperatorTest.Scenario<I,O>
构造器和说明 |
---|
FluxUsingTest() |
限定符和类型 | 方法和说明 |
---|---|
void |
checkEager() |
void |
checkErrorEager() |
void |
checkErrorNonEager() |
void |
checkNonEager() |
void |
factoryReturnsNull() |
void |
factoryThrowsEager() |
void |
normal() |
void |
normalEager() |
void |
resourceCleanupNull() |
void |
resourceSupplierNull() |
void |
resourceThrowsEager() |
void |
scanConditionalSubscriber() |
void |
scanFuseableSubscriber() |
void |
scanOperator() |
void |
scanSubscriber() |
void |
sourceFactoryAndResourceCleanupThrow() |
void |
sourceFactoryNull() |
void |
subscriberCancels() |
scenario
@Test public void resourceSupplierNull()
@Test public void sourceFactoryNull()
@Test public void resourceCleanupNull()
@Test public void normal()
@Test public void normalEager()
@Test public void checkNonEager()
@Test public void checkEager()
@Test public void checkErrorNonEager()
@Test public void checkErrorEager()
@Test public void resourceThrowsEager()
@Test public void factoryThrowsEager()
@Test public void factoryReturnsNull()
@Test public void subscriberCancels()
@Test public void sourceFactoryAndResourceCleanupThrow()
@Test public void scanOperator()
@Test public void scanSubscriber()
@Test public void scanConditionalSubscriber()
@Test public void scanFuseableSubscriber()