test_class.file: rxjava/src/test/java/io/reactivex/internal/observers/BlockingMultiObserverTest.java
test_class.identifier: BlockingMultiObserverTest
test_case.body: @Test
      public void blockingAwait() {
          final BlockingMultiObserver<Integer> bmo = new BlockingMultiObserver<Integer>();
  
          Schedulers.single().scheduleDirect(new Runnable() {
              @Override
              public void run() {
                  bmo.onSuccess(1);
              }
          }, 100, TimeUnit.MILLISECONDS);
  
          assertTrue(bmo.blockingAwait(1, TimeUnit.MINUTES));
      }
test_case.class_method_signature: BlockingMultiObserverTest.blockingAwait()
test_case.full_signature: @Test public void blockingAwait()
test_case.identifier: blockingAwait
test_case.invocations: scheduleDirect single onSuccess assertTrue blockingAwait
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void blockingAwait()
focal_class.declarator: value
focal_class.original_string: T value;
focal_class.type: T
focal_class.var_name: value
focal_class.declarator: error
focal_class.original_string: Throwable error;
focal_class.type: Throwable
focal_class.var_name: error
focal_class.declarator: d
focal_class.original_string: Disposable d;
focal_class.type: Disposable
focal_class.var_name: d
focal_class.declarator: cancelled
focal_class.modifier: volatile
focal_class.original_string: volatile boolean cancelled;
focal_class.type: boolean
focal_class.var_name: cancelled
focal_class.file: rxjava/src/main/java/io/reactivex/internal/observers/BlockingMultiObserver.java
focal_class.identifier: BlockingMultiObserver
focal_class.interfaces: implements SingleObserver<T>, CompletableObserver, MaybeObserver<T>
focal_class.class_method_signature: BlockingMultiObserver.BlockingMultiObserver()
focal_class.full_signature: public  BlockingMultiObserver()
focal_class.identifier: BlockingMultiObserver
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.signature:  BlockingMultiObserver()
focal_class.class_method_signature: BlockingMultiObserver.dispose()
focal_class.full_signature:  void dispose()
focal_class.identifier: dispose
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void dispose()
focal_class.class_method_signature: BlockingMultiObserver.onSubscribe(Disposable d)
focal_class.full_signature: @Override public void onSubscribe(Disposable d)
focal_class.identifier: onSubscribe
focal_class.modifiers: @Override public
focal_class.parameters: (Disposable d)
focal_class.return: void
focal_class.signature: void onSubscribe(Disposable d)
focal_class.class_method_signature: BlockingMultiObserver.onSuccess(T value)
focal_class.full_signature: @Override public void onSuccess(T value)
focal_class.identifier: onSuccess
focal_class.modifiers: @Override public
focal_class.parameters: (T value)
focal_class.return: void
focal_class.signature: void onSuccess(T value)
focal_class.class_method_signature: BlockingMultiObserver.onError(Throwable e)
focal_class.full_signature: @Override public void onError(Throwable e)
focal_class.identifier: onError
focal_class.modifiers: @Override public
focal_class.parameters: (Throwable e)
focal_class.return: void
focal_class.signature: void onError(Throwable e)
focal_class.class_method_signature: BlockingMultiObserver.onComplete()
focal_class.full_signature: @Override public void onComplete()
focal_class.identifier: onComplete
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void onComplete()
focal_class.class_method_signature: BlockingMultiObserver.blockingGet()
focal_class.full_signature: public T blockingGet()
focal_class.identifier: blockingGet
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: T
focal_class.signature: T blockingGet()
focal_class.class_method_signature: BlockingMultiObserver.blockingGet(T defaultValue)
focal_class.full_signature: public T blockingGet(T defaultValue)
focal_class.identifier: blockingGet
focal_class.modifiers: public
focal_class.parameters: (T defaultValue)
focal_class.return: T
focal_class.signature: T blockingGet(T defaultValue)
focal_class.class_method_signature: BlockingMultiObserver.blockingGetError()
focal_class.full_signature: public Throwable blockingGetError()
focal_class.identifier: blockingGetError
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Throwable
focal_class.signature: Throwable blockingGetError()
focal_class.class_method_signature: BlockingMultiObserver.blockingGetError(long timeout, TimeUnit unit)
focal_class.full_signature: public Throwable blockingGetError(long timeout, TimeUnit unit)
focal_class.identifier: blockingGetError
focal_class.modifiers: public
focal_class.parameters: (long timeout, TimeUnit unit)
focal_class.return: Throwable
focal_class.signature: Throwable blockingGetError(long timeout, TimeUnit unit)
focal_class.class_method_signature: BlockingMultiObserver.blockingAwait(long timeout, TimeUnit unit)
focal_class.full_signature: public boolean blockingAwait(long timeout, TimeUnit unit)
focal_class.identifier: blockingAwait
focal_class.modifiers: public
focal_class.parameters: (long timeout, TimeUnit unit)
focal_class.return: boolean
focal_class.signature: boolean blockingAwait(long timeout, TimeUnit unit)
focal_class.superclass: extends CountDownLatch
focal_method.body: public boolean blockingAwait(long timeout, TimeUnit unit) {
          if (getCount() != 0) {
              try {
                  BlockingHelper.verifyNonBlocking();
                  if (!await(timeout, unit)) {
                      dispose();
                      return false;
                  }
              } catch (InterruptedException ex) {
                  dispose();
                  throw ExceptionHelper.wrapOrThrow(ex);
              }
          }
          Throwable ex = error;
          if (ex != null) {
              throw ExceptionHelper.wrapOrThrow(ex);
          }
          return true;
      }
focal_method.class_method_signature: BlockingMultiObserver.blockingAwait(long timeout, TimeUnit unit)
focal_method.full_signature: public boolean blockingAwait(long timeout, TimeUnit unit)
focal_method.identifier: blockingAwait
focal_method.invocations: getCount verifyNonBlocking await dispose dispose wrapOrThrow wrapOrThrow
focal_method.modifiers: public
focal_method.parameters: (long timeout, TimeUnit unit)
focal_method.return: boolean
focal_method.signature: boolean blockingAwait(long timeout, TimeUnit unit)