reactor.core.publisher

类 FluxBufferPredicateTest

java.lang.Object

reactor.core.publisher.FluxBufferPredicateTest

public class FluxBufferPredicateTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxBufferPredicateTest()

方法概要

限定符和类型	方法和说明
void	bufferSupplierReturnsNull()
void	bufferSupplierThrows()
void	bufferSupplierThrowsLater()
void	discardOnCancel()
void	discardOnError()
void	discardOnPredicateError()
void	discardRaceWithOnNext_bufferAdds()
void	discardRaceWithOnNext_bufferUntilCutBeforeWithMatch()
void	discardRaceWithOnNext_bufferUntilWithMatch()
void	discardRaceWithOnNext_bufferWhileWithNoMatch()
void	mainErrorUntil()
void	mainErrorUntilOther()
void	mainErrorWhile()
void	multipleTriggersOfEmptyBufferKeepInitialBuffer()
void	normalUntil()
void	normalUntilOther()
void	normalWhile()
void	normalWhileDoesntInitiallyMatch()
void	normalWhileDoesntMatch()
void	onCompletionBeforeLastBoundaryBufferEmitted()
void	onNextRaceWithRequest()
void	onNextRaceWithRequestOfTwo()
void	predicateErrorUntil()
void	predicateErrorUntilOther()
void	predicateErrorWhile()
void	requestBounded()
void	requestBoundedConditionalFusesDemands()
void	requestBoundedSeveralInitial()
void	requestRaceWithOnNext()
void	requestRaceWithOnNextLoops()
void	requestRemainingBuffersAfterBufferEmission()
void	requestSwitchingToMaxRequestsSourceOnlyOnceMore()
void	requestUnboundedFromStartRequestsSourceOnce()
void	scanMain()
void	scanMainCancelled()
void	scanOperator()
void	testBufferPredicateUntilCutBeforeIncludesBoundaryFirst()
void	testBufferPredicateUntilIncludesBoundaryLast()
void	testBufferPredicateUntilIncludesBoundaryLastAfter()
void	testBufferPredicateWhileDoesntIncludeBoundary()
void	testBufferUntilNoExtraRequestFromConcurrentEmitAndRequest()
void	testBufferUntilNoExtraRequestFromEmit()
void	untilChangedDisposesStateOnCancel()
void	untilChangedDisposesStateOnComplete()
void	untilChangedDisposesStateOnError()
void	untilChangedNoRepetition()
void	untilChangedNoSharedState()
void	untilChangedSomeRepetition()
void	untilChangedWithKeySelector()

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

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

构造器详细资料

FluxBufferPredicateTest

public FluxBufferPredicateTest()

方法详细资料

normalUntil

@Test
public void normalUntil()

onCompletionBeforeLastBoundaryBufferEmitted

@Test
public void onCompletionBeforeLastBoundaryBufferEmitted()

mainErrorUntil

@Test
public void mainErrorUntil()

predicateErrorUntil

@Test
public void predicateErrorUntil()

normalUntilOther

@Test
public void normalUntilOther()

mainErrorUntilOther

@Test
public void mainErrorUntilOther()

predicateErrorUntilOther

@Test
public void predicateErrorUntilOther()

untilChangedNoRepetition

@Test
public void untilChangedNoRepetition()

untilChangedWithKeySelector

@Test
public void untilChangedWithKeySelector()

untilChangedNoSharedState

@Test
public void untilChangedNoSharedState()

untilChangedSomeRepetition

@Test
public void untilChangedSomeRepetition()

untilChangedDisposesStateOnComplete

@Test
public void untilChangedDisposesStateOnComplete()

untilChangedDisposesStateOnError

@Test
public void untilChangedDisposesStateOnError()

untilChangedDisposesStateOnCancel

@Test
public void untilChangedDisposesStateOnCancel()

normalWhile

@Test
public void normalWhile()

normalWhileDoesntInitiallyMatch

@Test
public void normalWhileDoesntInitiallyMatch()

normalWhileDoesntMatch

@Test
public void normalWhileDoesntMatch()

mainErrorWhile

@Test
public void mainErrorWhile()

predicateErrorWhile

@Test
public void predicateErrorWhile()

bufferSupplierThrows

@Test
public void bufferSupplierThrows()

bufferSupplierThrowsLater

@Test
public void bufferSupplierThrowsLater()

bufferSupplierReturnsNull

@Test
public void bufferSupplierReturnsNull()

multipleTriggersOfEmptyBufferKeepInitialBuffer

@Test
public void multipleTriggersOfEmptyBufferKeepInitialBuffer()

requestBounded

@Test
public void requestBounded()

requestBoundedSeveralInitial

@Test
public void requestBoundedSeveralInitial()

requestRemainingBuffersAfterBufferEmission

@Test
public void requestRemainingBuffersAfterBufferEmission()

requestRaceWithOnNext

@Test
public void requestRaceWithOnNext()

onNextRaceWithRequest

@Test
public void onNextRaceWithRequest()

onNextRaceWithRequestOfTwo

@Test
public void onNextRaceWithRequestOfTwo()

requestRaceWithOnNextLoops

@Test
 @Tag(value="slow")
public void requestRaceWithOnNextLoops()

requestUnboundedFromStartRequestsSourceOnce

@Test
public void requestUnboundedFromStartRequestsSourceOnce()

requestSwitchingToMaxRequestsSourceOnlyOnceMore

@Test
public void requestSwitchingToMaxRequestsSourceOnlyOnceMore()

requestBoundedConditionalFusesDemands

@Test
public void requestBoundedConditionalFusesDemands()

testBufferPredicateUntilIncludesBoundaryLast

@Test
public void testBufferPredicateUntilIncludesBoundaryLast()

testBufferPredicateUntilIncludesBoundaryLastAfter

@Test
public void testBufferPredicateUntilIncludesBoundaryLastAfter()

testBufferPredicateUntilCutBeforeIncludesBoundaryFirst

@Test
public void testBufferPredicateUntilCutBeforeIncludesBoundaryFirst()

testBufferPredicateWhileDoesntIncludeBoundary

@Test
public void testBufferPredicateWhileDoesntIncludeBoundary()

scanOperator

@Test
public void scanOperator()

scanMain

@Test
public void scanMain()

scanMainCancelled

@Test
public void scanMainCancelled()

discardOnCancel

@Test
public void discardOnCancel()

discardOnPredicateError

@Test
public void discardOnPredicateError()

discardOnError

@Test
public void discardOnError()

discardRaceWithOnNext_bufferAdds

@Test
public void discardRaceWithOnNext_bufferAdds()

discardRaceWithOnNext_bufferUntilWithMatch

@Test
public void discardRaceWithOnNext_bufferUntilWithMatch()

discardRaceWithOnNext_bufferUntilCutBeforeWithMatch

@Test
public void discardRaceWithOnNext_bufferUntilCutBeforeWithMatch()

discardRaceWithOnNext_bufferWhileWithNoMatch

@Test
public void discardRaceWithOnNext_bufferWhileWithNoMatch()

testBufferUntilNoExtraRequestFromEmit

@Test
public void testBufferUntilNoExtraRequestFromEmit()

testBufferUntilNoExtraRequestFromConcurrentEmitAndRequest

@Test
public void testBufferUntilNoExtraRequestFromConcurrentEmitAndRequest()