com.github.davidmoten.rx2.internal.flowable

Class FlowableMergeInterleavedTest

java.lang.Object

com.github.davidmoten.rx2.internal.flowable.FlowableMergeInterleavedTest

public final class FlowableMergeInterleavedTest
extends Object

Constructor Summary

Constructors

Constructor and Description
FlowableMergeInterleavedTest()

Method Summary

Modifier and Type	Method and Description
void	testFlatMap()
void	testInterleaveAsync()
void	testInterleaveCancel()
void	testInterleaveCompletingStreamsDifferentSize()
void	testInterleaveCompletingStreamsWithEmpty()
void	testInterleaveInfiniteStreamWithFiniteStream()
void	testInterleaveInfiniteStreamWithNever()
void	testInterleaveInfiniteStreamWithNeverReversed()
void	testInterleaveOneStream()
void	testInterleaveOneStreamEmpty()
void	testInterleaveTwoCompletingStreamsSameSize()
void	testInterleaveTwoInfiniteStreams()
void	testInterleaveTwoInfiniteStreamsRequestFive()
void	testInterleaveTwoInfiniteStreamsRequestOne()
void	testManySources()
void	testMergeWithErrorDelayed()
void	testMergeWithErrorNoDelay()
void	testSourcesError()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowableMergeInterleavedTest

public FlowableMergeInterleavedTest()

Method Detail

testInterleaveTwoInfiniteStreams

public void testInterleaveTwoInfiniteStreams()

testInterleaveTwoInfiniteStreamsRequestOne

public void testInterleaveTwoInfiniteStreamsRequestOne()

testInterleaveTwoInfiniteStreamsRequestFive

public void testInterleaveTwoInfiniteStreamsRequestFive()

testInterleaveOneStream

public void testInterleaveOneStream()

testInterleaveOneStreamEmpty

public void testInterleaveOneStreamEmpty()

testInterleaveInfiniteStreamWithFiniteStream

public void testInterleaveInfiniteStreamWithFiniteStream()

testInterleaveInfiniteStreamWithNever

public void testInterleaveInfiniteStreamWithNever()

testInterleaveInfiniteStreamWithNeverReversed

public void testInterleaveInfiniteStreamWithNeverReversed()

testInterleaveTwoCompletingStreamsSameSize

public void testInterleaveTwoCompletingStreamsSameSize()

testInterleaveCompletingStreamsDifferentSize

public void testInterleaveCompletingStreamsDifferentSize()

testInterleaveCompletingStreamsWithEmpty

public void testInterleaveCompletingStreamsWithEmpty()

testMergeWithErrorDelayed

public void testMergeWithErrorDelayed()

testMergeWithErrorNoDelay

public void testMergeWithErrorNoDelay()

testInterleaveAsync

public void testInterleaveAsync()

testInterleaveCancel

public void testInterleaveCancel()

testSourcesError

public void testSourcesError()

testManySources

public void testManySources()

testFlatMap

public void testFlatMap()