@Test
public void orderedOnNextRace() {

    for (int i = 0; i < TestHelper.RACE_LONG_LOOPS; i++) {
        TestSubscriber<Integer> ts = new TestSubscriber<Integer>(1);
        Disposable d = Disposables.empty();
        final QueueDrainSubscriber<Integer, Integer, Integer> qd = createOrdered(ts, d);
        ts.onSubscribe(new BooleanSubscription());
        qd.requested(Long.MAX_VALUE);
        Runnable r1 = new Runnable() {
            @Override
            public void run() {
                qd.onNext(1);
            }
        };
        TestHelper.race(r1, r1);
        ts.assertValuesOnly(1, 1);
    }
}