reactor.core.publisher

类 FluxDoFinallyTest

java.lang.Object

reactor.core.publisher.FluxDoFinallyTest

所有已实现的接口:

java.util.function.Consumer<SignalType>

public class FluxDoFinallyTest
extends java.lang.Object
implements java.util.function.Consumer<SignalType>

构造器概要

构造器

构造器和说明
FluxDoFinallyTest()

方法概要

限定符和类型	方法和说明
void	accept(SignalType signalType)
void	before()
void	callbackThrows()
void	callbackThrowsConditional()
void	gh951_withConsumerInSubscribe()
void	gh951_withoutConsumerInSubscribe()
void	normalCancel()
void	normalCancelConditional()
void	normalEmpty()
void	normalEmptyConditional()
void	normalError()
void	normalErrorConditional()
void	normalJust()
void	normalJustConditional()
void	normalTake()
void	normalTakeConditional()
void	nullCallback()
void	scanOperator()
void	scanSubscriber()
void	severalInARowExecutedInReverseOrder()

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

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

从接口继承的方法 java.util.function.Consumer

andThen

构造器详细资料

FluxDoFinallyTest

public FluxDoFinallyTest()

方法详细资料

before

@BeforeEach
public void before()

accept

public void accept(SignalType signalType)

指定者:

accept 在接口中 java.util.function.Consumer<SignalType>

normalJust

@Test
public void normalJust()

normalEmpty

@Test
public void normalEmpty()

normalError

@Test
public void normalError()

normalCancel

@Test
public void normalCancel()

normalTake

@Test
public void normalTake()

normalJustConditional

@Test
public void normalJustConditional()

normalEmptyConditional

@Test
public void normalEmptyConditional()

normalErrorConditional

@Test
public void normalErrorConditional()

normalCancelConditional

@Test
public void normalCancelConditional()

normalTakeConditional

@Test
public void normalTakeConditional()

nullCallback

@Test
public void nullCallback()

callbackThrows

@Test
public void callbackThrows()

callbackThrowsConditional

@Test
public void callbackThrowsConditional()

severalInARowExecutedInReverseOrder

@Test
public void severalInARowExecutedInReverseOrder()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

gh951_withoutConsumerInSubscribe

@Test
public void gh951_withoutConsumerInSubscribe()

gh951_withConsumerInSubscribe

@Test
public void gh951_withConsumerInSubscribe()