com.github.davidmoten.rx2.flowable

Class TransformersTest

java.lang.Object

com.github.davidmoten.rx2.flowable.TransformersTest

public class TransformersTest
extends Object

Constructor Summary

Constructors

Constructor and Description
TransformersTest()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)
void	testBufferMaxCountAndTimeout()
void	testBufferMaxCountAndTimeoutAsyncCountWins()
void	testBufferMaxCountAndTimeoutAsyncTimeoutWins()
void	testBufferTimeoutSourceError()
void	testInsert()
void	testInsertBackpressure()
void	testInsertCancel()
void	testInsertError()
void	testInsertMapperError()
void	testInsertNoOnNextOrCompleteEventsProcessedAfterMapperError()
void	testInsertNoOnNextOrErrorEventsProcessedAfterMapperError()
void	testInsertNothing()
void	testInsertSourceError()
void	testInsertTimeoutCancel()
void	testInsertTimeoutValueError()
void	testInsertWithDelays()
void	testIsUtilityClass()
void	testStatisticsOnEmptyStream()
void	testStatisticsOnMultipleElements()
void	testStatisticsOnSingleElement()
void	testStatisticsPairOnEmptyStream()
void	testStatisticsPairOnMultipleElements()
void	testStatisticsPairOnSingleElement()
void	testToString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformersTest

public TransformersTest()

Method Detail

testIsUtilityClass

public void testIsUtilityClass()

testStatisticsOnEmptyStream

public void testStatisticsOnEmptyStream()

testStatisticsOnSingleElement

public void testStatisticsOnSingleElement()

testStatisticsOnMultipleElements

public void testStatisticsOnMultipleElements()

testStatisticsPairOnEmptyStream

public void testStatisticsPairOnEmptyStream()

testStatisticsPairOnSingleElement

public void testStatisticsPairOnSingleElement()

testStatisticsPairOnMultipleElements

public void testStatisticsPairOnMultipleElements()

testToString

public void testToString()

testInsert

public void testInsert()

testInsertWithDelays

public void testInsertWithDelays()

testInsertBackpressure

public void testInsertBackpressure()

testInsertSourceError

public void testInsertSourceError()

testInsertError

public void testInsertError()

testInsertCancel

public void testInsertCancel()

testInsertMapperError

public void testInsertMapperError()

testInsertNothing

public void testInsertNothing()

testInsertNoOnNextOrCompleteEventsProcessedAfterMapperError

public void testInsertNoOnNextOrCompleteEventsProcessedAfterMapperError()

testInsertNoOnNextOrErrorEventsProcessedAfterMapperError

public void testInsertNoOnNextOrErrorEventsProcessedAfterMapperError()

testBufferMaxCountAndTimeout

public void testBufferMaxCountAndTimeout()

testBufferMaxCountAndTimeoutAsyncCountWins

public void testBufferMaxCountAndTimeoutAsyncCountWins()

testBufferMaxCountAndTimeoutAsyncTimeoutWins

public void testBufferMaxCountAndTimeoutAsyncTimeoutWins()

testBufferTimeoutSourceError

public void testBufferTimeoutSourceError()

testInsertTimeoutValueError

public void testInsertTimeoutValueError()

testInsertTimeoutCancel

public void testInsertTimeoutCancel()

main

public static void main(String[] args)