test_class.declarator: testException = new Throwable()
test_class.modifier: private final
test_class.original_string: private final Throwable testException = new Throwable();
test_class.type: Throwable
test_class.var_name: testException
test_class.file: rxjava/src/test/java/io/reactivex/subjects/AsyncSubjectTest.java
test_class.identifier: AsyncSubjectTest
test_class.superclass: extends SubjectTest<Integer>
test_case.body: @Test
      public void cancelRace() {
          AsyncSubject<Object> p = AsyncSubject.create();
  
          for (int i = 0; i < TestHelper.RACE_DEFAULT_LOOPS; i++) {
              final TestObserver<Object> to1 = p.test();
              final TestObserver<Object> to2 = p.test();
  
              Runnable r1 = new Runnable() {
                  @Override
                  public void run() {
                      to1.cancel();
                  }
              };
  
              Runnable r2 = new Runnable() {
                  @Override
                  public void run() {
                      to2.cancel();
                  }
              };
  
              TestHelper.race(r1, r2);
          }
      }
test_case.class_method_signature: AsyncSubjectTest.cancelRace()
test_case.full_signature: @Test public void cancelRace()
test_case.identifier: cancelRace
test_case.invocations: create test test cancel cancel race
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void cancelRace()
focal_class.declarator: EMPTY = new AsyncDisposable[0]
focal_class.modifier: @SuppressWarnings("rawtypes")
      static final
focal_class.original_string: @SuppressWarnings("rawtypes")
      static final AsyncDisposable[] EMPTY = new AsyncDisposable[0];
focal_class.type: AsyncDisposable[]
focal_class.var_name: EMPTY
focal_class.declarator: TERMINATED = new AsyncDisposable[0]
focal_class.modifier: @SuppressWarnings("rawtypes")
      static final
focal_class.original_string: @SuppressWarnings("rawtypes")
      static final AsyncDisposable[] TERMINATED = new AsyncDisposable[0];
focal_class.type: AsyncDisposable[]
focal_class.var_name: TERMINATED
focal_class.declarator: subscribers
focal_class.modifier: final
focal_class.original_string: final AtomicReference<AsyncDisposable<T>[]> subscribers;
focal_class.type: AtomicReference<AsyncDisposable<T>[]>
focal_class.var_name: subscribers
focal_class.declarator: error
focal_class.original_string: Throwable error;
focal_class.type: Throwable
focal_class.var_name: error
focal_class.declarator: value
focal_class.original_string: T value;
focal_class.type: T
focal_class.var_name: value
focal_class.file: rxjava/src/main/java/io/reactivex/subjects/AsyncSubject.java
focal_class.identifier: AsyncSubject
focal_class.class_method_signature: AsyncSubject.create()
focal_class.full_signature: @CheckReturnValue @NonNull public static AsyncSubject<T> create()
focal_class.identifier: create
focal_class.modifiers: @CheckReturnValue @NonNull public static
focal_class.parameters: ()
focal_class.return: AsyncSubject<T>
focal_class.signature: AsyncSubject<T> create()
focal_class.class_method_signature: AsyncSubject.AsyncSubject()
focal_class.full_signature: @SuppressWarnings("unchecked")  AsyncSubject()
focal_class.identifier: AsyncSubject
focal_class.modifiers: @SuppressWarnings("unchecked")
focal_class.parameters: ()
focal_class.signature:  AsyncSubject()
focal_class.class_method_signature: AsyncSubject.onSubscribe(Disposable s)
focal_class.full_signature: @Override public void onSubscribe(Disposable s)
focal_class.identifier: onSubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (Disposable s)
focal_class.return: void
focal_class.signature: void onSubscribe(Disposable s)
focal_class.class_method_signature: AsyncSubject.onNext(T t)
focal_class.full_signature: @Override public void onNext(T t)
focal_class.identifier: onNext
focal_class.modifiers: @Override public
focal_class.parameters: (T t)
focal_class.return: void
focal_class.signature: void onNext(T t)
focal_class.class_method_signature: AsyncSubject.onError(Throwable t)
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public void onError(Throwable t)
focal_class.identifier: onError
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: (Throwable t)
focal_class.return: void
focal_class.signature: void onError(Throwable t)
focal_class.class_method_signature: AsyncSubject.onComplete()
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public void onComplete()
focal_class.identifier: onComplete
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void onComplete()
focal_class.class_method_signature: AsyncSubject.hasObservers()
focal_class.full_signature: @Override public boolean hasObservers()
focal_class.identifier: hasObservers
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasObservers()
focal_class.class_method_signature: AsyncSubject.hasThrowable()
focal_class.full_signature: @Override public boolean hasThrowable()
focal_class.identifier: hasThrowable
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasThrowable()
focal_class.class_method_signature: AsyncSubject.hasComplete()
focal_class.full_signature: @Override public boolean hasComplete()
focal_class.identifier: hasComplete
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasComplete()
focal_class.class_method_signature: AsyncSubject.getThrowable()
focal_class.full_signature: @Override public Throwable getThrowable()
focal_class.identifier: getThrowable
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Throwable
focal_class.signature: Throwable getThrowable()
focal_class.class_method_signature: AsyncSubject.subscribeActual(Observer<? super T> s)
focal_class.full_signature: @Override protected void subscribeActual(Observer<? super T> s)
focal_class.identifier: subscribeActual
focal_class.modifiers: @Override protected
focal_class.parameters: (Observer<? super T> s)
focal_class.return: void
focal_class.signature: void subscribeActual(Observer<? super T> s)
focal_class.class_method_signature: AsyncSubject.add(AsyncDisposable<T> ps)
focal_class.full_signature:  boolean add(AsyncDisposable<T> ps)
focal_class.identifier: add
focal_class.parameters: (AsyncDisposable<T> ps)
focal_class.return: boolean
focal_class.signature: boolean add(AsyncDisposable<T> ps)
focal_class.class_method_signature: AsyncSubject.remove(AsyncDisposable<T> ps)
focal_class.full_signature: @SuppressWarnings("unchecked") void remove(AsyncDisposable<T> ps)
focal_class.identifier: remove
focal_class.modifiers: @SuppressWarnings("unchecked")
focal_class.parameters: (AsyncDisposable<T> ps)
focal_class.return: void
focal_class.signature: void remove(AsyncDisposable<T> ps)
focal_class.class_method_signature: AsyncSubject.hasValue()
focal_class.full_signature: public boolean hasValue()
focal_class.identifier: hasValue
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasValue()
focal_class.class_method_signature: AsyncSubject.getValue()
focal_class.full_signature: @Nullable public T getValue()
focal_class.identifier: getValue
focal_class.modifiers: @Nullable public
focal_class.parameters: ()
focal_class.return: T
focal_class.signature: T getValue()
focal_class.class_method_signature: AsyncSubject.getValues()
focal_class.full_signature: public Object[] getValues()
focal_class.identifier: getValues
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Object[]
focal_class.signature: Object[] getValues()
focal_class.class_method_signature: AsyncSubject.getValues(T[] array)
focal_class.full_signature: public T[] getValues(T[] array)
focal_class.identifier: getValues
focal_class.modifiers: public
focal_class.parameters: (T[] array)
focal_class.return: T[]
focal_class.signature: T[] getValues(T[] array)
focal_class.superclass: extends Subject<T>
focal_method.body: @CheckReturnValue
      @NonNull
      public static <T> AsyncSubject<T> create() {
          return new AsyncSubject<T>();
      }
focal_method.class_method_signature: AsyncSubject.create()
focal_method.full_signature: @CheckReturnValue @NonNull public static AsyncSubject<T> create()
focal_method.identifier: create
focal_method.modifiers: @CheckReturnValue @NonNull public static
focal_method.parameters: ()
focal_method.return: AsyncSubject<T>
focal_method.signature: AsyncSubject<T> create()