reactor.core.publisher

类 FluxPeekTest

java.lang.Object

reactor.test.publisher.BaseOperatorTest<I,Flux<I>,O,Flux<O>>

reactor.test.publisher.FluxOperatorTest<java.lang.String,java.lang.String>

reactor.core.publisher.FluxPeekTest

public class FluxPeekTest
extends FluxOperatorTest<java.lang.String,java.lang.String>

嵌套类概要

从类继承的嵌套类/接口 reactor.test.publisher.FluxOperatorTest

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxPeekTest()

方法概要

限定符和类型	方法和说明
void	afterTerminateCallbackFatalIsThrownDirectly()
void	asyncFusionAvailable()
void	callbackError()
void	completeCallbackError()
void	conditionalFusionAvailable()
void	conditionalFusionAvailableWithFuseable()
void	doOnErrorPredicate()
void	doOnErrorPredicateNot()
void	empty()
void	error()
void	errorCallbackError()
void	errorCallbackError2()
void	errorCallbackErrorWithParallel()
void	errorStrategyResumeDropsNext()
void	never()
void	neverCancel()
void	normal()
void	nullSource()
void	scanOperator()
void	scanSubscriber()
void	should_reduce_to_10_events_conditional()
void	should_reduce_to_10_events()
void	syncCompleteCalled()
void	syncdoAfterTerminateCalled()
void	syncdoOnTerminateCalled()
void	syncdoOnTerminateCalled2()
void	syncdoOnTerminateCalled3()
void	syncFusionAvailable()

从类继承的方法 reactor.test.publisher.FluxOperatorTest

scenario

从类继承的方法 reactor.test.publisher.BaseOperatorTest

assertPrePostState, cancelOnSubscribe, errorOnSubscribe, initDefaultScenario, sequenceOfNextAndCancel, sequenceOfNextAndComplete, sequenceOfNextAndError, sequenceOfNextWithCallbackError

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FluxPeekTest

public FluxPeekTest()

方法详细资料

nullSource

@Test
public void nullSource()

normal

@Test
public void normal()

error

@Test
public void error()

empty

@Test
public void empty()

never

@Test
public void never()

neverCancel

@Test
public void neverCancel()

callbackError

@Test
public void callbackError()

completeCallbackError

@Test
public void completeCallbackError()

errorCallbackError

@Test
public void errorCallbackError()

errorCallbackError2

@Test
public void errorCallbackError2()

errorCallbackErrorWithParallel

@Test
public void errorCallbackErrorWithParallel()

afterTerminateCallbackFatalIsThrownDirectly

@Test
public void afterTerminateCallbackFatalIsThrownDirectly()

syncFusionAvailable

@Test
public void syncFusionAvailable()

asyncFusionAvailable

@Test
public void asyncFusionAvailable()

conditionalFusionAvailable

@Test
public void conditionalFusionAvailable()

conditionalFusionAvailableWithFuseable

@Test
public void conditionalFusionAvailableWithFuseable()

syncCompleteCalled

@Test
public void syncCompleteCalled()

syncdoAfterTerminateCalled

@Test
public void syncdoAfterTerminateCalled()

syncdoOnTerminateCalled

@Test
public void syncdoOnTerminateCalled()

syncdoOnTerminateCalled2

@Test
public void syncdoOnTerminateCalled2()

syncdoOnTerminateCalled3

@Test
public void syncdoOnTerminateCalled3()

should_reduce_to_10_events

@Test
public void should_reduce_to_10_events()

should_reduce_to_10_events_conditional

@Test
public void should_reduce_to_10_events_conditional()

doOnErrorPredicate

@Test
public void doOnErrorPredicate()

doOnErrorPredicateNot

@Test
public void doOnErrorPredicateNot()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

errorStrategyResumeDropsNext

@Test
public void errorStrategyResumeDropsNext()