@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); } }
@Override public final long requested() { return requested.get(); }
QueueDrainSubscriber extends QueueDrainSubscriberPad4 implements FlowableSubscriber<T>, QueueDrain<U, V> { @Override public final long requested() { return requested.get(); } }
QueueDrainSubscriber extends QueueDrainSubscriberPad4 implements FlowableSubscriber<T>, QueueDrain<U, V> { @Override public final long requested() { return requested.get(); } QueueDrainSubscriber(Subscriber<? super V> actual, SimplePlainQueue<U> queue); }
QueueDrainSubscriber extends QueueDrainSubscriberPad4 implements FlowableSubscriber<T>, QueueDrain<U, V> { @Override public final long requested() { return requested.get(); } QueueDrainSubscriber(Subscriber<? super V> actual, SimplePlainQueue<U> queue); @Override final boolean cancelled(); @Override final boolean done(); @Override final boolean enter(); final boolean fastEnter(); @Override boolean accept(Subscriber<? super V> a, U v); @Override final Throwable error(); @Override final int leave(int m); @Override final long requested(); @Override final long produced(long n); final void requested(long n); }
QueueDrainSubscriber extends QueueDrainSubscriberPad4 implements FlowableSubscriber<T>, QueueDrain<U, V> { @Override public final long requested() { return requested.get(); } QueueDrainSubscriber(Subscriber<? super V> actual, SimplePlainQueue<U> queue); @Override final boolean cancelled(); @Override final boolean done(); @Override final boolean enter(); final boolean fastEnter(); @Override boolean accept(Subscriber<? super V> a, U v); @Override final Throwable error(); @Override final int leave(int m); @Override final long requested(); @Override final long produced(long n); final void requested(long n);  }