reactor.core.publisher

类 FluxPublishMulticastTest

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.FluxPublishMulticastTest

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

嵌套类概要

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

FluxOperatorTest.Scenario<I,O>

构造器概要

构造器

构造器和说明
FluxPublishMulticastTest()

方法概要

限定符和类型	方法和说明
void	cancelComposes()
void	cancelComposes2()
void	failPrefetch()
void	gh870()
void	innerCanFuse()
void	normalCancelBeforeComplete()
void	pairWise()
void	scanCancelFuseableMulticaster()
void	scanCancelMulticaster()
void	scanMulticaster()
void	scanMulticastInner()
void	scanOperator()
void	subsequentSum()
void	subsequentSumAsync()
void	subsequentSumHidden()
void	suppressedSubscriber()
void	syncCancelBeforeComplete()

从类继承的方法 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

构造器详细资料

FluxPublishMulticastTest

public FluxPublishMulticastTest()

方法详细资料

failPrefetch

@Test
public void failPrefetch()

subsequentSum

@Test
public void subsequentSum()

subsequentSumHidden

@Test
public void subsequentSumHidden()

subsequentSumAsync

@Test
public void subsequentSumAsync()

cancelComposes

@Test
public void cancelComposes()

cancelComposes2

@Test
public void cancelComposes2()

pairWise

@Test
public void pairWise()

innerCanFuse

@Test
public void innerCanFuse()

suppressedSubscriber

@Test
public void suppressedSubscriber()

syncCancelBeforeComplete

@Test
public void syncCancelBeforeComplete()

normalCancelBeforeComplete

@Test
public void normalCancelBeforeComplete()

scanOperator

@Test
public void scanOperator()

scanMulticaster

@Test
public void scanMulticaster()

scanMulticastInner

@Test
public void scanMulticastInner()

scanCancelMulticaster

@Test
public void scanCancelMulticaster()

scanCancelFuseableMulticaster

@Test
public void scanCancelFuseableMulticaster()

gh870

@Test
public void gh870()
                  throws java.lang.Exception

抛出:

java.lang.Exception