reactor.core.publisher

类 FluxStreamTest

java.lang.Object

reactor.core.publisher.FluxStreamTest

public class FluxStreamTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxStreamTest()

方法概要

限定符和类型	方法和说明
void	intermediateCloseIdempotent()
void	iteratorReturnsNull()
void	normal()
void	normalBackpressured()
void	normalBackpressuredExact()
void	nullStream()
void	nullSupplier()
void	nullSupplierErrorsAtSubscription()
void	scanOperator()
void	streamAlreadyConsumed()
void	streamClosedOnCancelConditional()
void	streamClosedOnCancelNormal()
void	streamClosedOnCancelSlowPathConditional()
void	streamClosedOnCancelSlowPathNormal()
void	streamClosedOnCompletionConditional()
void	streamClosedOnCompletionNormal()
void	streamClosedOnCompletionSlowPathConditional()
void	streamClosedOnCompletionSlowPathNormal()
void	streamClosedOnErrorConditional()
void	streamClosedOnErrorNormal()
void	streamClosedOnErrorSlowPathConditional()
void	streamClosedOnErrorSlowPathNormal()
void	streamClosedOnNullContentConditional()
void	streamClosedOnNullContentNormal()
void	streamClosedOnNullContentSlowPathConditional()
void	streamClosedOnNullContentSlowPathNormal()
void	streamClosedOnPollCompletionConditional()
void	streamClosedOnPollCompletionNormal()
void	streamCloseFailureDroppedConditional()
void	streamCloseFailureDroppedNormal()
void	streamConsumedBySubscription()
void	streamGeneratedPerSubscription()

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

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

构造器详细资料

FluxStreamTest

public FluxStreamTest()

方法详细资料

nullStream

@Test
public void nullStream()

nullSupplier

@Test
public void nullSupplier()

normal

@Test
public void normal()

normalBackpressured

@Test
public void normalBackpressured()

normalBackpressuredExact

@Test
public void normalBackpressuredExact()

iteratorReturnsNull

@Test
public void iteratorReturnsNull()

streamAlreadyConsumed

@Test
public void streamAlreadyConsumed()

streamConsumedBySubscription

@Test
public void streamConsumedBySubscription()

streamGeneratedPerSubscription

@Test
public void streamGeneratedPerSubscription()

nullSupplierErrorsAtSubscription

@Test
public void nullSupplierErrorsAtSubscription()

streamClosedOnCancelNormal

@Test
public void streamClosedOnCancelNormal()

streamClosedOnCancelSlowPathNormal

@Test
public void streamClosedOnCancelSlowPathNormal()

streamClosedOnCompletionNormal

@Test
public void streamClosedOnCompletionNormal()

streamClosedOnCompletionSlowPathNormal

@Test
public void streamClosedOnCompletionSlowPathNormal()

streamClosedOnErrorNormal

@Test
public void streamClosedOnErrorNormal()

streamClosedOnErrorSlowPathNormal

@Test
public void streamClosedOnErrorSlowPathNormal()

streamClosedOnNullContentNormal

@Test
public void streamClosedOnNullContentNormal()

streamClosedOnNullContentSlowPathNormal

@Test
public void streamClosedOnNullContentSlowPathNormal()

streamClosedOnPollCompletionNormal

@Test
public void streamClosedOnPollCompletionNormal()

streamCloseFailureDroppedNormal

@Test
public void streamCloseFailureDroppedNormal()

streamClosedOnCancelConditional

@Test
public void streamClosedOnCancelConditional()

streamClosedOnCancelSlowPathConditional

@Test
public void streamClosedOnCancelSlowPathConditional()

streamClosedOnCompletionConditional

@Test
public void streamClosedOnCompletionConditional()

streamClosedOnCompletionSlowPathConditional

@Test
public void streamClosedOnCompletionSlowPathConditional()

streamClosedOnErrorConditional

@Test
public void streamClosedOnErrorConditional()

streamClosedOnErrorSlowPathConditional

@Test
public void streamClosedOnErrorSlowPathConditional()

streamClosedOnNullContentConditional

@Test
public void streamClosedOnNullContentConditional()

streamClosedOnNullContentSlowPathConditional

@Test
public void streamClosedOnNullContentSlowPathConditional()

streamClosedOnPollCompletionConditional

@Test
public void streamClosedOnPollCompletionConditional()

streamCloseFailureDroppedConditional

@Test
public void streamCloseFailureDroppedConditional()

intermediateCloseIdempotent

@Test
public void intermediateCloseIdempotent()

scanOperator

@Test
public void scanOperator()