test_class.file: rxjava/src/test/java/io/reactivex/internal/observers/LambdaObserverTest.java
test_class.identifier: LambdaObserverTest
test_case.body: @Test
      public void onNextThrows() {
          final List<Object> received = new ArrayList<Object>();
  
          LambdaObserver<Object> o = new LambdaObserver<Object>(new Consumer<Object>() {
              @Override
              public void accept(Object v) throws Exception {
                  throw new TestException();
              }
          },
          new Consumer<Throwable>() {
              @Override
              public void accept(Throwable e) throws Exception {
                  received.add(e);
              }
          }, new Action() {
              @Override
              public void run() throws Exception {
                  received.add(100);
              }
          }, new Consumer<Disposable>() {
              @Override
              public void accept(Disposable s) throws Exception {
              }
          });
  
          assertFalse(o.isDisposed());
  
          Observable.just(1).subscribe(o);
  
          assertTrue(received.toString(), received.get(0) instanceof TestException);
          assertEquals(received.toString(), 1, received.size());
  
          assertTrue(o.isDisposed());
      }
test_case.class_method_signature: LambdaObserverTest.onNextThrows()
test_case.full_signature: @Test public void onNextThrows()
test_case.identifier: onNextThrows
test_case.invocations: add add assertFalse isDisposed subscribe just assertTrue toString get assertEquals toString size assertTrue isDisposed
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void onNextThrows()
focal_class.declarator: serialVersionUID = -7251123623727029452L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = -7251123623727029452L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: onNext
focal_class.modifier: final
focal_class.original_string: final Consumer<? super T> onNext;
focal_class.type: Consumer<? super T>
focal_class.var_name: onNext
focal_class.declarator: onError
focal_class.modifier: final
focal_class.original_string: final Consumer<? super Throwable> onError;
focal_class.type: Consumer<? super Throwable>
focal_class.var_name: onError
focal_class.declarator: onComplete
focal_class.modifier: final
focal_class.original_string: final Action onComplete;
focal_class.type: Action
focal_class.var_name: onComplete
focal_class.declarator: onSubscribe
focal_class.modifier: final
focal_class.original_string: final Consumer<? super Disposable> onSubscribe;
focal_class.type: Consumer<? super Disposable>
focal_class.var_name: onSubscribe
focal_class.file: rxjava/src/main/java/io/reactivex/internal/observers/LambdaObserver.java
focal_class.identifier: LambdaObserver
focal_class.interfaces: implements Observer<T>, Disposable, LambdaConsumerIntrospection
focal_class.class_method_signature: LambdaObserver.LambdaObserver(Consumer<? super T> onNext, Consumer<? super Throwable> onError,
              Action onComplete,
              Consumer<? super Disposable> onSubscribe)
focal_class.full_signature: public  LambdaObserver(Consumer<? super T> onNext, Consumer<? super Throwable> onError,
              Action onComplete,
              Consumer<? super Disposable> onSubscribe)
focal_class.identifier: LambdaObserver
focal_class.modifiers: public
focal_class.parameters: (Consumer<? super T> onNext, Consumer<? super Throwable> onError,
              Action onComplete,
              Consumer<? super Disposable> onSubscribe)
focal_class.signature:  LambdaObserver(Consumer<? super T> onNext, Consumer<? super Throwable> onError,
              Action onComplete,
              Consumer<? super Disposable> onSubscribe)
focal_class.class_method_signature: LambdaObserver.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: LambdaObserver.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: LambdaObserver.onError(Throwable t)
focal_class.full_signature: @Override public void onError(Throwable t)
focal_class.identifier: onError
focal_class.modifiers: @Override public
focal_class.parameters: (Throwable t)
focal_class.return: void
focal_class.signature: void onError(Throwable t)
focal_class.class_method_signature: LambdaObserver.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: LambdaObserver.dispose()
focal_class.full_signature: @Override public void dispose()
focal_class.identifier: dispose
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void dispose()
focal_class.class_method_signature: LambdaObserver.isDisposed()
focal_class.full_signature: @Override public boolean isDisposed()
focal_class.identifier: isDisposed
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isDisposed()
focal_class.class_method_signature: LambdaObserver.hasCustomOnError()
focal_class.full_signature: @Override public boolean hasCustomOnError()
focal_class.identifier: hasCustomOnError
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasCustomOnError()
focal_class.superclass: extends AtomicReference<Disposable>
focal_method.body: @Override
      public boolean isDisposed() {
          return get() == DisposableHelper.DISPOSED;
      }
focal_method.class_method_signature: LambdaObserver.isDisposed()
focal_method.full_signature: @Override public boolean isDisposed()
focal_method.identifier: isDisposed
focal_method.invocations: get
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: boolean
focal_method.signature: boolean isDisposed()