@Test
public void doubleRequest() {

    TestSubscriber<Integer> ts = TestSubscriber.create(0);
    TestingDeferredScalarSubscriber ds = new TestingDeferredScalarSubscriber(ts);
    ds.setupDownstream();
    ds.onNext(1);
    ts.request(1);
    ts.request(1);
    ds.onComplete();
    ts.assertValue(1);
    ts.assertNoErrors();
    ts.assertComplete();
}