reactor.core.publisher

类 MonoCollectTest

java.lang.Object

reactor.core.publisher.MonoCollectTest

public class MonoCollectTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
MonoCollectTest()

方法概要

限定符和类型	方法和说明
void	actionThrows()
void	discardCancelCompleteRace()
void	discardCancelNextRace()
void	discardElementAndBufferOnAccumulatorLateFailure()
void	discardElementOnAccumulatorFailure()
void	discardListElementsOnCancel()
void	discardListElementsOnError()
void	discardWholeArrayOnCancel()
void	discardWholeArrayOnError()
void	normal() 自定义收集 Flux.collect(Collector)
void	normalBackpressured()
void	nullAction()
void	nullSource()
void	nullSupplier()
void	scanOperator()
void	scanSubscriber()
void	supplierReturnsNull()
void	supplierThrows()

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

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

构造器详细资料

MonoCollectTest

public MonoCollectTest()

方法详细资料

nullSource

@Test
public void nullSource()

nullSupplier

@Test
public void nullSupplier()

nullAction

@Test
public void nullAction()

normal

@Test
public void normal()

自定义收集 Flux.collect(Collector)

normalBackpressured

@Test
public void normalBackpressured()

supplierThrows

@Test
public void supplierThrows()

supplierReturnsNull

@Test
public void supplierReturnsNull()

actionThrows

@Test
public void actionThrows()

scanOperator

@Test
public void scanOperator()

scanSubscriber

@Test
public void scanSubscriber()

discardElementOnAccumulatorFailure

@Test
public void discardElementOnAccumulatorFailure()

discardElementAndBufferOnAccumulatorLateFailure

@Test
public void discardElementAndBufferOnAccumulatorLateFailure()

discardListElementsOnError

@Test
public void discardListElementsOnError()

discardListElementsOnCancel

@Test
public void discardListElementsOnCancel()

discardWholeArrayOnError

@Test
public void discardWholeArrayOnError()

discardWholeArrayOnCancel

@Test
public void discardWholeArrayOnCancel()

discardCancelNextRace

@Test
public void discardCancelNextRace()

discardCancelCompleteRace

@Test
public void discardCancelCompleteRace()