com.github.davidmoten.rx2.internal.flowable

Class FlowableStateMachineTest

java.lang.Object

com.github.davidmoten.rx2.internal.flowable.FlowableStateMachineTest

public final class FlowableStateMachineTest
extends Object

Constructor Summary

Constructors

Constructor and Description
FlowableStateMachineTest()

Method Summary

Modifier and Type	Method and Description
void	errorActionPassThrough()
void	errorActionThrows()
void	noActionTransition()
void	testAsync()
void	testCancel()
void	testCancelFromTransition()
void	testCompletionThrows()
void	testErrorPassThrough()
void	testInvalidRequestBatchSize()
void	testOnNextThrowsWithBurstSource()
void	testOnNextThrowsWithBurstSourceThatTerminatesWithError()
void	testPassThroughEmitterCompletesTwice()
void	testPassThroughEmitterErrorAfterCompletion()
void	testPassThroughEmitterOnNextAfterCompletion()
void	testPassThroughWithCustomCompletion()
void	testRequestBatchSize1()
void	testRequestBatchSize1WithBackpressure()
void	testRequestBatchSize1WithBackpressureRequestMoreThanAvailable()
void	testRequestBatchSize2()
void	testRequestBatchSize2WithBackpressure()
void	testStateFactoryReturnsNull()
void	testStateFactoryReturnsNullFromErrorStream()
void	testStateFactoryReturnsNullOnEmptySource()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowableStateMachineTest

public FlowableStateMachineTest()

Method Detail

testRequestBatchSize1

public void testRequestBatchSize1()

testPassThroughWithCustomCompletion

public void testPassThroughWithCustomCompletion()

testPassThroughEmitterCompletesTwice

public void testPassThroughEmitterCompletesTwice()

testPassThroughEmitterOnNextAfterCompletion

public void testPassThroughEmitterOnNextAfterCompletion()

testPassThroughEmitterErrorAfterCompletion

public void testPassThroughEmitterErrorAfterCompletion()

testCompletionThrows

public void testCompletionThrows()

testRequestBatchSize2

public void testRequestBatchSize2()

testErrorPassThrough

public void testErrorPassThrough()

testRequestBatchSize1WithBackpressure

public void testRequestBatchSize1WithBackpressure()

testRequestBatchSize1WithBackpressureRequestMoreThanAvailable

public void testRequestBatchSize1WithBackpressureRequestMoreThanAvailable()

testRequestBatchSize2WithBackpressure

public void testRequestBatchSize2WithBackpressure()

testStateFactoryReturnsNull

public void testStateFactoryReturnsNull()

testStateFactoryReturnsNullFromErrorStream

public void testStateFactoryReturnsNullFromErrorStream()

testOnNextThrowsWithBurstSource

public void testOnNextThrowsWithBurstSource()

testCancelFromTransition

public void testCancelFromTransition()

testInvalidRequestBatchSize

public void testInvalidRequestBatchSize()

testOnNextThrowsWithBurstSourceThatTerminatesWithError

public void testOnNextThrowsWithBurstSourceThatTerminatesWithError()

testStateFactoryReturnsNullOnEmptySource

public void testStateFactoryReturnsNullOnEmptySource()

errorActionThrows

public void errorActionThrows()

errorActionPassThrough

public void errorActionPassThrough()

testAsync

public void testAsync()

testCancel

public void testCancel()

noActionTransition

public void noActionTransition()