should request -1 for infinite concode_field_sep PlaceHolder placeHolder concode_field_sep void testRequestFromDecoupledOperatorThatRequestsN concode_elem_sep void testRequestThroughTakeWhereRequestIsSmallerThanTake concode_elem_sep void testRequestFromDecoupledOperator concode_elem_sep void testRequestThroughMap concode_elem_sep void testRequestFromChainedOperator concode_elem_sep void testOnStartCalledOnceViaSubscribe concode_elem_sep void testOnStartCalledOnceViaLift concode_elem_sep void testOnStartRequestsAreAdditive concode_elem_sep void testNegativeRequestThrowsIllegalArgumentException concode_elem_sep void testRequestToObservable concode_elem_sep void testRequestFromFinalSubscribeWithRequestValue concode_elem_sep void testOnStartCalledOnceViaUnsafeSubscribe concode_elem_sep void testRequestThroughTakeThatReducesRequest concode_elem_sep void testOnStartRequestsAreAdditiveAndOverflowBecomesMaxValue
void function ( ) { Subscriber < String > loc0 = new TestSubscriber < String > ( ) ; final AtomicLong loc1 = new AtomicLong ( ) ; loc0 . setProducer ( new Producer ( ) { @ Override public void request ( long arg0 ) { loc1 . set ( arg0 ) ; } } ) ; assertEquals ( Long . MAX_VALUE , loc1 . get ( ) ) ; }