com.github.davidmoten.rx2.internal.flowable

Class FlowableMaxRequestTest

java.lang.Object

com.github.davidmoten.rx2.internal.flowable.FlowableMaxRequestTest

public class FlowableMaxRequestTest
extends Object

Constructor Summary

Constructors

Constructor and Description
FlowableMaxRequestTest()

Method Summary

Modifier and Type	Method and Description
void	checkCancel()
void	checkEmptyMaxRequestOneDownstreamRequestsMaxValue()
void	checkErrorMaxRequestOneDownstreamRequestsMaxValue()
void	checkMaxRequestOneDownstreamRequestMaxValue()
void	checkMaxRequestOneDownstreamRequestTen()
void	checkMaxRequestThreeDownstreamRequestMaxValue()
void	checkMaxRequestThreeDownstreamRequestTen()
void	checkMaxRequestTwoDownstreamRequestMaxValue()
void	checkMaxRequestTwoDownstreamRequestTen()
void	checkRequestsWhileEmitting()
void	checkSingleMaxRequestMaxValueDownstreamRequestsMaxValue()
void	checkSingleMaxRequestOneDownstreamRequestsMaxValue()
void	checkSingleMaxRequestTwoDownstreamRequestsMaxValue()
void	testAsync()
void	testAsyncMaxRequestIsMax()
void	testAsyncNotMaxValue()
void	testMaxRequestIsMaxValue()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowableMaxRequestTest

public FlowableMaxRequestTest()

Method Detail

checkEmptyMaxRequestOneDownstreamRequestsMaxValue

public void checkEmptyMaxRequestOneDownstreamRequestsMaxValue()

checkErrorMaxRequestOneDownstreamRequestsMaxValue

public void checkErrorMaxRequestOneDownstreamRequestsMaxValue()

checkSingleMaxRequestOneDownstreamRequestsMaxValue

public void checkSingleMaxRequestOneDownstreamRequestsMaxValue()

checkSingleMaxRequestTwoDownstreamRequestsMaxValue

public void checkSingleMaxRequestTwoDownstreamRequestsMaxValue()

checkSingleMaxRequestMaxValueDownstreamRequestsMaxValue

public void checkSingleMaxRequestMaxValueDownstreamRequestsMaxValue()

checkMaxRequestOneDownstreamRequestMaxValue

public void checkMaxRequestOneDownstreamRequestMaxValue()

checkMaxRequestTwoDownstreamRequestMaxValue

public void checkMaxRequestTwoDownstreamRequestMaxValue()

checkMaxRequestThreeDownstreamRequestMaxValue

public void checkMaxRequestThreeDownstreamRequestMaxValue()

checkMaxRequestOneDownstreamRequestTen

public void checkMaxRequestOneDownstreamRequestTen()

checkMaxRequestTwoDownstreamRequestTen

public void checkMaxRequestTwoDownstreamRequestTen()

checkMaxRequestThreeDownstreamRequestTen

public void checkMaxRequestThreeDownstreamRequestTen()

checkRequestsWhileEmitting

public void checkRequestsWhileEmitting()

checkCancel

public void checkCancel()

testAsync

public void testAsync()

testAsyncNotMaxValue

public void testAsyncNotMaxValue()

testAsyncMaxRequestIsMax

public void testAsyncMaxRequestIsMax()

testMaxRequestIsMaxValue

public void testMaxRequestIsMaxValue()