test_class.file: rxjava/src/test/java/io/reactivex/internal/subscribers/QueueDrainSubscriberTest.java
test_class.identifier: QueueDrainSubscriberTest
test_case.body: @Test
      public void unorderedOnNextRace() {
          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 = createUnordered(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);
          }
      }
test_case.class_method_signature: QueueDrainSubscriberTest.unorderedOnNextRace()
test_case.full_signature: @Test public void unorderedOnNextRace()
test_case.identifier: unorderedOnNextRace
test_case.invocations: empty createUnordered onSubscribe requested onNext race assertValuesOnly
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void unorderedOnNextRace()
focal_class.declarator: actual
focal_class.modifier: protected final
focal_class.original_string: protected final Subscriber<? super V> actual;
focal_class.type: Subscriber<? super V>
focal_class.var_name: actual
focal_class.declarator: queue
focal_class.modifier: protected final
focal_class.original_string: protected final SimplePlainQueue<U> queue;
focal_class.type: SimplePlainQueue<U>
focal_class.var_name: queue
focal_class.declarator: cancelled
focal_class.modifier: protected volatile
focal_class.original_string: protected volatile boolean cancelled;
focal_class.type: boolean
focal_class.var_name: cancelled
focal_class.declarator: done
focal_class.modifier: protected volatile
focal_class.original_string: protected volatile boolean done;
focal_class.type: boolean
focal_class.var_name: done
focal_class.declarator: error
focal_class.modifier: protected
focal_class.original_string: protected Throwable error;
focal_class.type: Throwable
focal_class.var_name: error
focal_class.file: rxjava/src/main/java/io/reactivex/internal/subscribers/QueueDrainSubscriber.java
focal_class.identifier: QueueDrainSubscriber
focal_class.interfaces: implements FlowableSubscriber<T>, QueueDrain<U, V>
focal_class.class_method_signature: QueueDrainSubscriber.QueueDrainSubscriber(Subscriber<? super V> actual, SimplePlainQueue<U> queue)
focal_class.full_signature: public  QueueDrainSubscriber(Subscriber<? super V> actual, SimplePlainQueue<U> queue)
focal_class.identifier: QueueDrainSubscriber
focal_class.modifiers: public
focal_class.parameters: (Subscriber<? super V> actual, SimplePlainQueue<U> queue)
focal_class.signature:  QueueDrainSubscriber(Subscriber<? super V> actual, SimplePlainQueue<U> queue)
focal_class.class_method_signature: QueueDrainSubscriber.cancelled()
focal_class.full_signature: @Override public final boolean cancelled()
focal_class.identifier: cancelled
focal_class.modifiers: @Override public final
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean cancelled()
focal_class.class_method_signature: QueueDrainSubscriber.done()
focal_class.full_signature: @Override public final boolean done()
focal_class.identifier: done
focal_class.modifiers: @Override public final
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean done()
focal_class.class_method_signature: QueueDrainSubscriber.enter()
focal_class.full_signature: @Override public final boolean enter()
focal_class.identifier: enter
focal_class.modifiers: @Override public final
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean enter()
focal_class.class_method_signature: QueueDrainSubscriber.fastEnter()
focal_class.full_signature: public final boolean fastEnter()
focal_class.identifier: fastEnter
focal_class.modifiers: public final
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean fastEnter()
focal_class.class_method_signature: QueueDrainSubscriber.fastPathEmitMax(U value, boolean delayError, Disposable dispose)
focal_class.full_signature: protected final void fastPathEmitMax(U value, boolean delayError, Disposable dispose)
focal_class.identifier: fastPathEmitMax
focal_class.modifiers: protected final
focal_class.parameters: (U value, boolean delayError, Disposable dispose)
focal_class.return: void
focal_class.signature: void fastPathEmitMax(U value, boolean delayError, Disposable dispose)
focal_class.class_method_signature: QueueDrainSubscriber.fastPathOrderedEmitMax(U value, boolean delayError, Disposable dispose)
focal_class.full_signature: protected final void fastPathOrderedEmitMax(U value, boolean delayError, Disposable dispose)
focal_class.identifier: fastPathOrderedEmitMax
focal_class.modifiers: protected final
focal_class.parameters: (U value, boolean delayError, Disposable dispose)
focal_class.return: void
focal_class.signature: void fastPathOrderedEmitMax(U value, boolean delayError, Disposable dispose)
focal_class.class_method_signature: QueueDrainSubscriber.accept(Subscriber<? super V> a, U v)
focal_class.full_signature: @Override public boolean accept(Subscriber<? super V> a, U v)
focal_class.identifier: accept
focal_class.modifiers: @Override public
focal_class.parameters: (Subscriber<? super V> a, U v)
focal_class.return: boolean
focal_class.signature: boolean accept(Subscriber<? super V> a, U v)
focal_class.class_method_signature: QueueDrainSubscriber.error()
focal_class.full_signature: @Override public final Throwable error()
focal_class.identifier: error
focal_class.modifiers: @Override public final
focal_class.parameters: ()
focal_class.return: Throwable
focal_class.signature: Throwable error()
focal_class.class_method_signature: QueueDrainSubscriber.leave(int m)
focal_class.full_signature: @Override public final int leave(int m)
focal_class.identifier: leave
focal_class.modifiers: @Override public final
focal_class.parameters: (int m)
focal_class.return: int
focal_class.signature: int leave(int m)
focal_class.class_method_signature: QueueDrainSubscriber.requested()
focal_class.full_signature: @Override public final long requested()
focal_class.identifier: requested
focal_class.modifiers: @Override public final
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long requested()
focal_class.class_method_signature: QueueDrainSubscriber.produced(long n)
focal_class.full_signature: @Override public final long produced(long n)
focal_class.identifier: produced
focal_class.modifiers: @Override public final
focal_class.parameters: (long n)
focal_class.return: long
focal_class.signature: long produced(long n)
focal_class.class_method_signature: QueueDrainSubscriber.requested(long n)
focal_class.full_signature: public final void requested(long n)
focal_class.identifier: requested
focal_class.modifiers: public final
focal_class.parameters: (long n)
focal_class.return: void
focal_class.signature: void requested(long n)
focal_class.superclass: extends QueueDrainSubscriberPad4
focal_method.body: @Override
      public final long requested() {
          return requested.get();
      }
focal_method.class_method_signature: QueueDrainSubscriber.requested()
focal_method.full_signature: @Override public final long requested()
focal_method.identifier: requested
focal_method.invocations: get
focal_method.modifiers: @Override public final
focal_method.parameters: ()
focal_method.return: long
focal_method.signature: long requested()