reactor.test.publisher

类 BaseOperatorTest<I,PI extends org.reactivestreams.Publisher<? extends I>,O,PO extends org.reactivestreams.Publisher<? extends O>>

java.lang.Object

reactor.test.publisher.BaseOperatorTest<I,PI,O,PO>

直接已知子类:

FluxOperatorTest, MonoOperatorTest, ParallelOperatorTest, ReduceOperatorTest

public abstract class BaseOperatorTest<I,PI extends org.reactivestreams.Publisher<? extends I>,O,PO extends org.reactivestreams.Publisher<? extends O>>
extends java.lang.Object

作者:

Stephane Maldini

构造器概要

构造器

构造器和说明
BaseOperatorTest()

方法概要

限定符和类型	方法和说明
java.util.stream.Stream<org.junit.jupiter.api.DynamicTest>	assertPrePostState()
java.util.stream.Stream<org.junit.jupiter.api.DynamicTest>	cancelOnSubscribe()
java.util.stream.Stream<org.junit.jupiter.api.DynamicTest>	errorOnSubscribe()
void	initDefaultScenario()
java.util.stream.Stream<org.junit.jupiter.api.DynamicTest>	sequenceOfNextAndCancel()
java.util.stream.Stream<org.junit.jupiter.api.DynamicTest>	sequenceOfNextAndComplete()
java.util.stream.Stream<org.junit.jupiter.api.DynamicTest>	sequenceOfNextAndError()
java.util.stream.Stream<org.junit.jupiter.api.DynamicTest>	sequenceOfNextWithCallbackError()

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

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

构造器详细资料

BaseOperatorTest

public BaseOperatorTest()

方法详细资料

initDefaultScenario

@BeforeEach
public final void initDefaultScenario()

cancelOnSubscribe

@TestFactory
public final java.util.stream.Stream<org.junit.jupiter.api.DynamicTest> cancelOnSubscribe()

assertPrePostState

@TestFactory
public final java.util.stream.Stream<org.junit.jupiter.api.DynamicTest> assertPrePostState()

sequenceOfNextAndComplete

@TestFactory
public final java.util.stream.Stream<org.junit.jupiter.api.DynamicTest> sequenceOfNextAndComplete()

sequenceOfNextWithCallbackError

@TestFactory
public final java.util.stream.Stream<org.junit.jupiter.api.DynamicTest> sequenceOfNextWithCallbackError()

errorOnSubscribe

@TestFactory
public final java.util.stream.Stream<org.junit.jupiter.api.DynamicTest> errorOnSubscribe()

sequenceOfNextAndCancel

@TestFactory
public final java.util.stream.Stream<org.junit.jupiter.api.DynamicTest> sequenceOfNextAndCancel()

sequenceOfNextAndError

@TestFactory
public final java.util.stream.Stream<org.junit.jupiter.api.DynamicTest> sequenceOfNextAndError()