reactor.core.publisher

类 FluxSampleTest

java.lang.Object

reactor.core.publisher.FluxSampleTest

public class FluxSampleTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
FluxSampleTest()

方法概要

限定符和类型	方法和说明
void	completeImmediately(boolean which)
void	error1()
void	error2()
void	mainCompletesImmediately()
void	normal1()
void	normal2()
void	otherCompletesImmediately()
void	otherNull()
void	sampleIncludesLastItem()
void	scanMainSubscriber()
void	scanOtherSubscriber()
void	sourceErrorsBeforeSamplingNoEmission()
void	sourceNull()
void	sourceTerminatesBeforeSamplingEmits()
void	subscriberCancels()

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

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

构造器详细资料

FluxSampleTest

public FluxSampleTest()

方法详细资料

sourceNull

@Test
public void sourceNull()

otherNull

@Test
public void otherNull()

normal1

@Test
public void normal1()

normal2

@Test
public void normal2()

error1

@Test
public void error1()

error2

@Test
public void error2()

subscriberCancels

@Test
public void subscriberCancels()

completeImmediately

public void completeImmediately(boolean which)

mainCompletesImmediately

@Test
public void mainCompletesImmediately()

otherCompletesImmediately

@Test
public void otherCompletesImmediately()

sampleIncludesLastItem

@Test
public void sampleIncludesLastItem()

sourceTerminatesBeforeSamplingEmits

@Test
public void sourceTerminatesBeforeSamplingEmits()

sourceErrorsBeforeSamplingNoEmission

@Test
public void sourceErrorsBeforeSamplingNoEmission()

scanMainSubscriber

@Test
public void scanMainSubscriber()

scanOtherSubscriber

@Test
public void scanOtherSubscriber()