public class FluxSwitchMapTest
extends java.lang.Object
构造器和说明 |
---|
FluxSwitchMapTest() |
限定符和类型 | 方法和说明 |
---|---|
void |
doswitch(int prefetch) |
void |
innerError(int prefetch) |
void |
mainCompletesBefore(int prefetch) |
void |
mainError(int prefetch) |
void |
mapperReturnsNull(int prefetch) |
void |
mapperThrows(int prefetch) |
void |
noswitch(int prefetch) |
void |
noswitchBackpressuredZeroPrefetch() |
void |
scanOperator() |
void |
switchOnNextDynamically(int prefetch) |
void |
switchOnNextDynamicallyOnNext(int prefetch) |
void |
switchRegularQueue() |
void |
test2596() |
@Test @Timeout(value=2L, unit=MINUTES) @Tag(value="slow") public void test2596()
@ValueSource(ints={0,32}) public void noswitch(int prefetch)
@Test public void noswitchBackpressuredZeroPrefetch()
@ValueSource(ints={0,32}) public void doswitch(int prefetch)
@Test public void switchRegularQueue()
@ValueSource(ints={0,32}) public void mainCompletesBefore(int prefetch)
@ValueSource(ints={0,32}) public void mainError(int prefetch)
@ValueSource(ints={0,32}) public void innerError(int prefetch)
@ValueSource(ints={0,32}) public void mapperThrows(int prefetch)
@ValueSource(ints={0,32}) public void mapperReturnsNull(int prefetch)
@ValueSource(ints={0,32}) public void switchOnNextDynamically(int prefetch)
@ValueSource(ints={0,32}) public void switchOnNextDynamicallyOnNext(int prefetch)
@Test public void scanOperator()