reactor.core.publisher

类 FluxTakeTest

java.lang.Object

reactor.core.publisher.FluxTakeTest

public class FluxTakeTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxTakeTest()

方法概要

限定符和类型	方法和说明
void	aFluxCanBeLimited()
void	assertPrefetch()
void	failConditionalDoubleError()
void	failDoubleError()
void	failFusedDoubleError()
void	failNextIfTerminatedTake()
void	failNextIfTerminatedTakeConditional()
void	failNextIfTerminatedTakeFused()
void	failNextIfTerminatedTakeSourceConditional()
void	ignoreConditionalDoubleOnSubscribe()
void	ignoreDoubleComplete()
void	ignoreDoubleOnSubscribe()
void	ignoreFusedDoubleComplete()
void	normal()
void	normalBackpressured()
void	numberIsInvalid()
void	numberIsInvalidFused()
void	onSubscribeRaceRequestingShouldBeConsistentForTakeConditionalTest()
void	onSubscribeRaceRequestingShouldBeConsistentForTakeFuseableTest()
void	onSubscribeRaceRequestingShouldBeConsistentForTakeTest()
void	scanConditionalSubscriber()
void	scanFuseableOperator()
void	scanFuseableSubscriber()
void	scanOperator()
void	scanSubscriber()
void	sourceNull()
void	take()
void	takeBackpressured()
void	takeBackpressuredConditional()
void	takeBackpressuredSourceConditional()
void	takeCancel()
void	takeConditional()
void	takeConditionalCancel()
void	takeConditionalFused()
void	takeConditionalFusedCancel()
void	takeConditionalZeroCancelsWhenNoRequest()
void	takeConditionalZeroIgnoresRequestAndCancels()
void	takeFused()
void	takeFusedAsync()
void	takeFusedBackpressured()
void	takeFusedBackpressuredCancelled()
void	takeFusedCancel()
void	takeFusedSync()
void	takeNever()
void	takeNeverZero()
void	takeOverflowAttempt()
void	takeZero()
void	takeZeroCancelsWhenNoRequest()
void	takeZeroIgnoresRequestAndCancels()

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

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

构造器详细资料

FluxTakeTest

public FluxTakeTest()

方法详细资料

sourceNull

@Test
public void sourceNull()

numberIsInvalid

@Test
public void numberIsInvalid()

numberIsInvalidFused

@Test
public void numberIsInvalidFused()

normal

@Test
public void normal()

normalBackpressured

@Test
public void normalBackpressured()

takeZero

@Test
public void takeZero()

takeNever

@Test
public void takeNever()

takeNeverZero

@Test
public void takeNeverZero()

takeOverflowAttempt

@Test
public void takeOverflowAttempt()

aFluxCanBeLimited

@Test
public void aFluxCanBeLimited()

takeBackpressured

@Test
public void takeBackpressured()

takeFusedBackpressured

@Test
public void takeFusedBackpressured()

takeFusedBackpressuredCancelled

@Test
public void takeFusedBackpressuredCancelled()

takeBackpressuredConditional

@Test
public void takeBackpressuredConditional()

takeBackpressuredSourceConditional

@Test
public void takeBackpressuredSourceConditional()

failNextIfTerminatedTake

@Test
public void failNextIfTerminatedTake()

failNextIfTerminatedTakeFused

@Test
public void failNextIfTerminatedTakeFused()

failNextIfTerminatedTakeConditional

@Test
public void failNextIfTerminatedTakeConditional()

failNextIfTerminatedTakeSourceConditional

@Test
public void failNextIfTerminatedTakeSourceConditional()

take

@Test
public void take()

takeCancel

@Test
public void takeCancel()

takeFused

@Test
public void takeFused()

takeFusedSync

@Test
public void takeFusedSync()

takeFusedAsync

@Test
public void takeFusedAsync()

takeFusedCancel

@Test
public void takeFusedCancel()

takeConditional

@Test
public void takeConditional()

takeConditionalCancel

@Test
public void takeConditionalCancel()

takeConditionalFused

@Test
public void takeConditionalFused()

takeConditionalFusedCancel

@Test
public void takeConditionalFusedCancel()

failDoubleError

@Test
public void failDoubleError()

failConditionalDoubleError

@Test
public void failConditionalDoubleError()

failFusedDoubleError

@Test
public void failFusedDoubleError()

ignoreFusedDoubleComplete

@Test
public void ignoreFusedDoubleComplete()

ignoreDoubleComplete

@Test
public void ignoreDoubleComplete()

assertPrefetch

@Test
public void assertPrefetch()

ignoreDoubleOnSubscribe

@Test
public void ignoreDoubleOnSubscribe()

ignoreConditionalDoubleOnSubscribe

@Test
public void ignoreConditionalDoubleOnSubscribe()

takeZeroCancelsWhenNoRequest

@Test
public void takeZeroCancelsWhenNoRequest()

takeZeroIgnoresRequestAndCancels

@Test
public void takeZeroIgnoresRequestAndCancels()

takeConditionalZeroCancelsWhenNoRequest

@Test
public void takeConditionalZeroCancelsWhenNoRequest()

takeConditionalZeroIgnoresRequestAndCancels

@Test
public void takeConditionalZeroIgnoresRequestAndCancels()

scanOperator

@Test
public void scanOperator()

scanFuseableOperator

@Test
public void scanFuseableOperator()

scanSubscriber

@Test
public void scanSubscriber()

scanConditionalSubscriber

@Test
public void scanConditionalSubscriber()

scanFuseableSubscriber

@Test
public void scanFuseableSubscriber()

onSubscribeRaceRequestingShouldBeConsistentForTakeFuseableTest

@Test
 @Tag(value="slow")
public void onSubscribeRaceRequestingShouldBeConsistentForTakeFuseableTest()
                                                                                                throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

onSubscribeRaceRequestingShouldBeConsistentForTakeConditionalTest

@Test
 @Tag(value="slow")
public void onSubscribeRaceRequestingShouldBeConsistentForTakeConditionalTest()
                                                                                                   throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

onSubscribeRaceRequestingShouldBeConsistentForTakeTest

@Test
 @Tag(value="slow")
public void onSubscribeRaceRequestingShouldBeConsistentForTakeTest()
                                                                                        throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException