test_class.declarator: replaceWithImmediate = new Function<Scheduler, Scheduler>() {
          @Override
          public Scheduler apply(Scheduler t) {
              return ImmediateThinScheduler.INSTANCE;
          }
      }
test_class.original_string: Function<Scheduler, Scheduler> replaceWithImmediate = new Function<Scheduler, Scheduler>() {
          @Override
          public Scheduler apply(Scheduler t) {
              return ImmediateThinScheduler.INSTANCE;
          }
      };
test_class.type: Function<Scheduler, Scheduler>
test_class.var_name: replaceWithImmediate
test_class.declarator: initReplaceWithImmediate = new Function<Callable<Scheduler>, Scheduler>() {
          @Override
          public Scheduler apply(Callable<Scheduler> t) {
              return ImmediateThinScheduler.INSTANCE;
          }
      }
test_class.original_string: Function<Callable<Scheduler>, Scheduler> initReplaceWithImmediate = new Function<Callable<Scheduler>, Scheduler>() {
          @Override
          public Scheduler apply(Callable<Scheduler> t) {
              return ImmediateThinScheduler.INSTANCE;
          }
      };
test_class.type: Function<Callable<Scheduler>, Scheduler>
test_class.var_name: initReplaceWithImmediate
test_class.declarator: nullResultCallable = new Callable<Scheduler>() {
          @Override
          public Scheduler call() throws Exception {
              return null;
          }
      }
test_class.original_string: Callable<Scheduler> nullResultCallable = new Callable<Scheduler>() {
          @Override
          public Scheduler call() throws Exception {
              return null;
          }
      };
test_class.type: Callable<Scheduler>
test_class.var_name: nullResultCallable
test_class.declarator: unsafeDefault = new Callable<Scheduler>() {
          @Override
          public Scheduler call() throws Exception {
              throw new AssertionError("Default Scheduler instance should not have been evaluated");
          }
      }
test_class.original_string: Callable<Scheduler> unsafeDefault = new Callable<Scheduler>() {
          @Override
          public Scheduler call() throws Exception {
              throw new AssertionError("Default Scheduler instance should not have been evaluated");
          }
      };
test_class.type: Callable<Scheduler>
test_class.var_name: unsafeDefault
test_class.file: rxjava/src/test/java/io/reactivex/plugins/RxJavaPluginsTest.java
test_class.identifier: RxJavaPluginsTest
test_case.body: @Test
      public void isBug() {
          assertFalse(RxJavaPlugins.isBug(new RuntimeException()));
          assertFalse(RxJavaPlugins.isBug(new IOException()));
          assertFalse(RxJavaPlugins.isBug(new InterruptedException()));
          assertFalse(RxJavaPlugins.isBug(new InterruptedIOException()));
  
          assertTrue(RxJavaPlugins.isBug(new NullPointerException()));
          assertTrue(RxJavaPlugins.isBug(new IllegalArgumentException()));
          assertTrue(RxJavaPlugins.isBug(new IllegalStateException()));
          assertTrue(RxJavaPlugins.isBug(new MissingBackpressureException()));
          assertTrue(RxJavaPlugins.isBug(new ProtocolViolationException("")));
          assertTrue(RxJavaPlugins.isBug(new UndeliverableException(new TestException())));
          assertTrue(RxJavaPlugins.isBug(new CompositeException(new TestException())));
          assertTrue(RxJavaPlugins.isBug(new OnErrorNotImplementedException(new TestException())));
      }
test_case.class_method_signature: RxJavaPluginsTest.isBug()
test_case.full_signature: @Test public void isBug()
test_case.identifier: isBug
test_case.invocations: assertFalse isBug assertFalse isBug assertFalse isBug assertFalse isBug assertTrue isBug assertTrue isBug assertTrue isBug assertTrue isBug assertTrue isBug assertTrue isBug assertTrue isBug assertTrue isBug
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void isBug()
focal_class.declarator: errorHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Consumer<? super Throwable> errorHandler;
focal_class.type: Consumer<? super Throwable>
focal_class.var_name: errorHandler
focal_class.declarator: onScheduleHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Runnable, ? extends Runnable> onScheduleHandler;
focal_class.type: Function<? super Runnable, ? extends Runnable>
focal_class.var_name: onScheduleHandler
focal_class.declarator: onInitComputationHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Callable<Scheduler>, ? extends Scheduler> onInitComputationHandler;
focal_class.type: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.var_name: onInitComputationHandler
focal_class.declarator: onInitSingleHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Callable<Scheduler>, ? extends Scheduler> onInitSingleHandler;
focal_class.type: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.var_name: onInitSingleHandler
focal_class.declarator: onInitIoHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Callable<Scheduler>, ? extends Scheduler> onInitIoHandler;
focal_class.type: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.var_name: onInitIoHandler
focal_class.declarator: onInitNewThreadHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Callable<Scheduler>, ? extends Scheduler> onInitNewThreadHandler;
focal_class.type: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.var_name: onInitNewThreadHandler
focal_class.declarator: onComputationHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Scheduler, ? extends Scheduler> onComputationHandler;
focal_class.type: Function<? super Scheduler, ? extends Scheduler>
focal_class.var_name: onComputationHandler
focal_class.declarator: onSingleHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Scheduler, ? extends Scheduler> onSingleHandler;
focal_class.type: Function<? super Scheduler, ? extends Scheduler>
focal_class.var_name: onSingleHandler
focal_class.declarator: onIoHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Scheduler, ? extends Scheduler> onIoHandler;
focal_class.type: Function<? super Scheduler, ? extends Scheduler>
focal_class.var_name: onIoHandler
focal_class.declarator: onNewThreadHandler
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Scheduler, ? extends Scheduler> onNewThreadHandler;
focal_class.type: Function<? super Scheduler, ? extends Scheduler>
focal_class.var_name: onNewThreadHandler
focal_class.declarator: onFlowableAssembly
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile Function<? super Flowable, ? extends Flowable> onFlowableAssembly;
focal_class.type: Function<? super Flowable, ? extends Flowable>
focal_class.var_name: onFlowableAssembly
focal_class.declarator: onConnectableFlowableAssembly
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly;
focal_class.type: Function<? super ConnectableFlowable, ? extends ConnectableFlowable>
focal_class.var_name: onConnectableFlowableAssembly
focal_class.declarator: onObservableAssembly
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile Function<? super Observable, ? extends Observable> onObservableAssembly;
focal_class.type: Function<? super Observable, ? extends Observable>
focal_class.var_name: onObservableAssembly
focal_class.declarator: onConnectableObservableAssembly
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly;
focal_class.type: Function<? super ConnectableObservable, ? extends ConnectableObservable>
focal_class.var_name: onConnectableObservableAssembly
focal_class.declarator: onMaybeAssembly
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile Function<? super Maybe, ? extends Maybe> onMaybeAssembly;
focal_class.type: Function<? super Maybe, ? extends Maybe>
focal_class.var_name: onMaybeAssembly
focal_class.declarator: onSingleAssembly
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile Function<? super Single, ? extends Single> onSingleAssembly;
focal_class.type: Function<? super Single, ? extends Single>
focal_class.var_name: onSingleAssembly
focal_class.declarator: onCompletableAssembly
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile Function<? super Completable, ? extends Completable> onCompletableAssembly;
focal_class.type: Function<? super Completable, ? extends Completable>
focal_class.var_name: onCompletableAssembly
focal_class.declarator: onParallelAssembly
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile Function<? super ParallelFlowable, ? extends ParallelFlowable> onParallelAssembly;
focal_class.type: Function<? super ParallelFlowable, ? extends ParallelFlowable>
focal_class.var_name: onParallelAssembly
focal_class.declarator: onFlowableSubscribe
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> onFlowableSubscribe;
focal_class.type: BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber>
focal_class.var_name: onFlowableSubscribe
focal_class.declarator: onMaybeSubscribe
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile BiFunction<? super Maybe, ? super MaybeObserver, ? extends MaybeObserver> onMaybeSubscribe;
focal_class.type: BiFunction<? super Maybe, ? super MaybeObserver, ? extends MaybeObserver>
focal_class.var_name: onMaybeSubscribe
focal_class.declarator: onObservableSubscribe
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile BiFunction<? super Observable, ? super Observer, ? extends Observer> onObservableSubscribe;
focal_class.type: BiFunction<? super Observable, ? super Observer, ? extends Observer>
focal_class.var_name: onObservableSubscribe
focal_class.declarator: onSingleSubscribe
focal_class.modifier: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile
focal_class.original_string: @SuppressWarnings("rawtypes")
      @Nullable
      static volatile BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> onSingleSubscribe;
focal_class.type: BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver>
focal_class.var_name: onSingleSubscribe
focal_class.declarator: onCompletableSubscribe
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe;
focal_class.type: BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver>
focal_class.var_name: onCompletableSubscribe
focal_class.declarator: onBeforeBlocking
focal_class.modifier: @Nullable
      static volatile
focal_class.original_string: @Nullable
      static volatile BooleanSupplier onBeforeBlocking;
focal_class.type: BooleanSupplier
focal_class.var_name: onBeforeBlocking
focal_class.declarator: lockdown
focal_class.modifier: static volatile
focal_class.original_string: static volatile boolean lockdown;
focal_class.type: boolean
focal_class.var_name: lockdown
focal_class.declarator: failNonBlockingScheduler
focal_class.modifier: static volatile
focal_class.original_string: static volatile boolean failNonBlockingScheduler;
focal_class.type: boolean
focal_class.var_name: failNonBlockingScheduler
focal_class.file: rxjava/src/main/java/io/reactivex/plugins/RxJavaPlugins.java
focal_class.identifier: RxJavaPlugins
focal_class.class_method_signature: RxJavaPlugins.lockdown()
focal_class.full_signature: public static void lockdown()
focal_class.identifier: lockdown
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void lockdown()
focal_class.class_method_signature: RxJavaPlugins.isLockdown()
focal_class.full_signature: public static boolean isLockdown()
focal_class.identifier: isLockdown
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isLockdown()
focal_class.class_method_signature: RxJavaPlugins.setFailOnNonBlockingScheduler(boolean enable)
focal_class.full_signature: public static void setFailOnNonBlockingScheduler(boolean enable)
focal_class.identifier: setFailOnNonBlockingScheduler
focal_class.modifiers: public static
focal_class.parameters: (boolean enable)
focal_class.return: void
focal_class.signature: void setFailOnNonBlockingScheduler(boolean enable)
focal_class.class_method_signature: RxJavaPlugins.isFailOnNonBlockingScheduler()
focal_class.full_signature: public static boolean isFailOnNonBlockingScheduler()
focal_class.identifier: isFailOnNonBlockingScheduler
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isFailOnNonBlockingScheduler()
focal_class.class_method_signature: RxJavaPlugins.getComputationSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Scheduler, ? extends Scheduler> getComputationSchedulerHandler()
focal_class.identifier: getComputationSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Scheduler, ? extends Scheduler>
focal_class.signature: Function<? super Scheduler, ? extends Scheduler> getComputationSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.getErrorHandler()
focal_class.full_signature: @Nullable public static Consumer<? super Throwable> getErrorHandler()
focal_class.identifier: getErrorHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Consumer<? super Throwable>
focal_class.signature: Consumer<? super Throwable> getErrorHandler()
focal_class.class_method_signature: RxJavaPlugins.getInitComputationSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitComputationSchedulerHandler()
focal_class.identifier: getInitComputationSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.signature: Function<? super Callable<Scheduler>, ? extends Scheduler> getInitComputationSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.getInitIoSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitIoSchedulerHandler()
focal_class.identifier: getInitIoSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.signature: Function<? super Callable<Scheduler>, ? extends Scheduler> getInitIoSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.getInitNewThreadSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitNewThreadSchedulerHandler()
focal_class.identifier: getInitNewThreadSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.signature: Function<? super Callable<Scheduler>, ? extends Scheduler> getInitNewThreadSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.getInitSingleSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitSingleSchedulerHandler()
focal_class.identifier: getInitSingleSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Callable<Scheduler>, ? extends Scheduler>
focal_class.signature: Function<? super Callable<Scheduler>, ? extends Scheduler> getInitSingleSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.getIoSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Scheduler, ? extends Scheduler> getIoSchedulerHandler()
focal_class.identifier: getIoSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Scheduler, ? extends Scheduler>
focal_class.signature: Function<? super Scheduler, ? extends Scheduler> getIoSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.getNewThreadSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Scheduler, ? extends Scheduler> getNewThreadSchedulerHandler()
focal_class.identifier: getNewThreadSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Scheduler, ? extends Scheduler>
focal_class.signature: Function<? super Scheduler, ? extends Scheduler> getNewThreadSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.getScheduleHandler()
focal_class.full_signature: @Nullable public static Function<? super Runnable, ? extends Runnable> getScheduleHandler()
focal_class.identifier: getScheduleHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Runnable, ? extends Runnable>
focal_class.signature: Function<? super Runnable, ? extends Runnable> getScheduleHandler()
focal_class.class_method_signature: RxJavaPlugins.getSingleSchedulerHandler()
focal_class.full_signature: @Nullable public static Function<? super Scheduler, ? extends Scheduler> getSingleSchedulerHandler()
focal_class.identifier: getSingleSchedulerHandler
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Scheduler, ? extends Scheduler>
focal_class.signature: Function<? super Scheduler, ? extends Scheduler> getSingleSchedulerHandler()
focal_class.class_method_signature: RxJavaPlugins.initComputationScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler initComputationScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.identifier: initComputationScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Callable<Scheduler> defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler initComputationScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.initIoScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler initIoScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.identifier: initIoScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Callable<Scheduler> defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler initIoScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.initNewThreadScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler initNewThreadScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.identifier: initNewThreadScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Callable<Scheduler> defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler initNewThreadScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.initSingleScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler initSingleScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.identifier: initSingleScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Callable<Scheduler> defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler initSingleScheduler(@NonNull Callable<Scheduler> defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.onComputationScheduler(@NonNull Scheduler defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler onComputationScheduler(@NonNull Scheduler defaultScheduler)
focal_class.identifier: onComputationScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Scheduler defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler onComputationScheduler(@NonNull Scheduler defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.onError(@NonNull Throwable error)
focal_class.full_signature: public static void onError(@NonNull Throwable error)
focal_class.identifier: onError
focal_class.modifiers: public static
focal_class.parameters: (@NonNull Throwable error)
focal_class.return: void
focal_class.signature: void onError(@NonNull Throwable error)
focal_class.class_method_signature: RxJavaPlugins.isBug(Throwable error)
focal_class.full_signature: static boolean isBug(Throwable error)
focal_class.identifier: isBug
focal_class.modifiers: static
focal_class.parameters: (Throwable error)
focal_class.return: boolean
focal_class.signature: boolean isBug(Throwable error)
focal_class.class_method_signature: RxJavaPlugins.uncaught(@NonNull Throwable error)
focal_class.full_signature: static void uncaught(@NonNull Throwable error)
focal_class.identifier: uncaught
focal_class.modifiers: static
focal_class.parameters: (@NonNull Throwable error)
focal_class.return: void
focal_class.signature: void uncaught(@NonNull Throwable error)
focal_class.class_method_signature: RxJavaPlugins.onIoScheduler(@NonNull Scheduler defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler onIoScheduler(@NonNull Scheduler defaultScheduler)
focal_class.identifier: onIoScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Scheduler defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler onIoScheduler(@NonNull Scheduler defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.onNewThreadScheduler(@NonNull Scheduler defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler onNewThreadScheduler(@NonNull Scheduler defaultScheduler)
focal_class.identifier: onNewThreadScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Scheduler defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler onNewThreadScheduler(@NonNull Scheduler defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.onSchedule(@NonNull Runnable run)
focal_class.full_signature: @NonNull public static Runnable onSchedule(@NonNull Runnable run)
focal_class.identifier: onSchedule
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Runnable run)
focal_class.return: Runnable
focal_class.signature: Runnable onSchedule(@NonNull Runnable run)
focal_class.class_method_signature: RxJavaPlugins.onSingleScheduler(@NonNull Scheduler defaultScheduler)
focal_class.full_signature: @NonNull public static Scheduler onSingleScheduler(@NonNull Scheduler defaultScheduler)
focal_class.identifier: onSingleScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Scheduler defaultScheduler)
focal_class.return: Scheduler
focal_class.signature: Scheduler onSingleScheduler(@NonNull Scheduler defaultScheduler)
focal_class.class_method_signature: RxJavaPlugins.reset()
focal_class.full_signature: public static void reset()
focal_class.identifier: reset
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void reset()
focal_class.class_method_signature: RxJavaPlugins.setComputationSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.full_signature: public static void setComputationSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.identifier: setComputationSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setComputationSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.setErrorHandler(@Nullable Consumer<? super Throwable> handler)
focal_class.full_signature: public static void setErrorHandler(@Nullable Consumer<? super Throwable> handler)
focal_class.identifier: setErrorHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Consumer<? super Throwable> handler)
focal_class.return: void
focal_class.signature: void setErrorHandler(@Nullable Consumer<? super Throwable> handler)
focal_class.class_method_signature: RxJavaPlugins.setInitComputationSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.full_signature: public static void setInitComputationSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.identifier: setInitComputationSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setInitComputationSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.setInitIoSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.full_signature: public static void setInitIoSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.identifier: setInitIoSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setInitIoSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.setInitNewThreadSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.full_signature: public static void setInitNewThreadSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.identifier: setInitNewThreadSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setInitNewThreadSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.setInitSingleSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.full_signature: public static void setInitSingleSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.identifier: setInitSingleSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setInitSingleSchedulerHandler(@Nullable Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.setIoSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.full_signature: public static void setIoSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.identifier: setIoSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setIoSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.setNewThreadSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.full_signature: public static void setNewThreadSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.identifier: setNewThreadSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setNewThreadSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.setScheduleHandler(@Nullable Function<? super Runnable, ? extends Runnable> handler)
focal_class.full_signature: public static void setScheduleHandler(@Nullable Function<? super Runnable, ? extends Runnable> handler)
focal_class.identifier: setScheduleHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Runnable, ? extends Runnable> handler)
focal_class.return: void
focal_class.signature: void setScheduleHandler(@Nullable Function<? super Runnable, ? extends Runnable> handler)
focal_class.class_method_signature: RxJavaPlugins.setSingleSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.full_signature: public static void setSingleSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.identifier: setSingleSchedulerHandler
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.return: void
focal_class.signature: void setSingleSchedulerHandler(@Nullable Function<? super Scheduler, ? extends Scheduler> handler)
focal_class.class_method_signature: RxJavaPlugins.unlock()
focal_class.full_signature: static void unlock()
focal_class.identifier: unlock
focal_class.modifiers: static
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void unlock()
focal_class.class_method_signature: RxJavaPlugins.getOnCompletableAssembly()
focal_class.full_signature: @Nullable public static Function<? super Completable, ? extends Completable> getOnCompletableAssembly()
focal_class.identifier: getOnCompletableAssembly
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Completable, ? extends Completable>
focal_class.signature: Function<? super Completable, ? extends Completable> getOnCompletableAssembly()
focal_class.class_method_signature: RxJavaPlugins.getOnCompletableSubscribe()
focal_class.full_signature: @Nullable public static BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> getOnCompletableSubscribe()
focal_class.identifier: getOnCompletableSubscribe
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver>
focal_class.signature: BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> getOnCompletableSubscribe()
focal_class.class_method_signature: RxJavaPlugins.getOnFlowableAssembly()
focal_class.full_signature: @SuppressWarnings("rawtypes") @Nullable public static Function<? super Flowable, ? extends Flowable> getOnFlowableAssembly()
focal_class.identifier: getOnFlowableAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super Flowable, ? extends Flowable>
focal_class.signature: Function<? super Flowable, ? extends Flowable> getOnFlowableAssembly()
focal_class.class_method_signature: RxJavaPlugins.getOnConnectableFlowableAssembly()
focal_class.full_signature: @SuppressWarnings("rawtypes") @Nullable public static Function<? super ConnectableFlowable, ? extends ConnectableFlowable> getOnConnectableFlowableAssembly()
focal_class.identifier: getOnConnectableFlowableAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super ConnectableFlowable, ? extends ConnectableFlowable>
focal_class.signature: Function<? super ConnectableFlowable, ? extends ConnectableFlowable> getOnConnectableFlowableAssembly()
focal_class.class_method_signature: RxJavaPlugins.getOnFlowableSubscribe()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> getOnFlowableSubscribe()
focal_class.identifier: getOnFlowableSubscribe
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber>
focal_class.signature: BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> getOnFlowableSubscribe()
focal_class.class_method_signature: RxJavaPlugins.getOnMaybeSubscribe()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static BiFunction<? super Maybe, ? super MaybeObserver, ? extends MaybeObserver> getOnMaybeSubscribe()
focal_class.identifier: getOnMaybeSubscribe
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: BiFunction<? super Maybe, ? super MaybeObserver, ? extends MaybeObserver>
focal_class.signature: BiFunction<? super Maybe, ? super MaybeObserver, ? extends MaybeObserver> getOnMaybeSubscribe()
focal_class.class_method_signature: RxJavaPlugins.getOnMaybeAssembly()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static Function<? super Maybe, ? extends Maybe> getOnMaybeAssembly()
focal_class.identifier: getOnMaybeAssembly
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: Function<? super Maybe, ? extends Maybe>
focal_class.signature: Function<? super Maybe, ? extends Maybe> getOnMaybeAssembly()
focal_class.class_method_signature: RxJavaPlugins.getOnSingleAssembly()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static Function<? super Single, ? extends Single> getOnSingleAssembly()
focal_class.identifier: getOnSingleAssembly
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: Function<? super Single, ? extends Single>
focal_class.signature: Function<? super Single, ? extends Single> getOnSingleAssembly()
focal_class.class_method_signature: RxJavaPlugins.getOnSingleSubscribe()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> getOnSingleSubscribe()
focal_class.identifier: getOnSingleSubscribe
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver>
focal_class.signature: BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> getOnSingleSubscribe()
focal_class.class_method_signature: RxJavaPlugins.getOnObservableAssembly()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static Function<? super Observable, ? extends Observable> getOnObservableAssembly()
focal_class.identifier: getOnObservableAssembly
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: Function<? super Observable, ? extends Observable>
focal_class.signature: Function<? super Observable, ? extends Observable> getOnObservableAssembly()
focal_class.class_method_signature: RxJavaPlugins.getOnConnectableObservableAssembly()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static Function<? super ConnectableObservable, ? extends ConnectableObservable> getOnConnectableObservableAssembly()
focal_class.identifier: getOnConnectableObservableAssembly
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: Function<? super ConnectableObservable, ? extends ConnectableObservable>
focal_class.signature: Function<? super ConnectableObservable, ? extends ConnectableObservable> getOnConnectableObservableAssembly()
focal_class.class_method_signature: RxJavaPlugins.getOnObservableSubscribe()
focal_class.full_signature: @Nullable @SuppressWarnings("rawtypes") public static BiFunction<? super Observable, ? super Observer, ? extends Observer> getOnObservableSubscribe()
focal_class.identifier: getOnObservableSubscribe
focal_class.modifiers: @Nullable @SuppressWarnings("rawtypes") public static
focal_class.parameters: ()
focal_class.return: BiFunction<? super Observable, ? super Observer, ? extends Observer>
focal_class.signature: BiFunction<? super Observable, ? super Observer, ? extends Observer> getOnObservableSubscribe()
focal_class.class_method_signature: RxJavaPlugins.setOnCompletableAssembly(@Nullable Function<? super Completable, ? extends Completable> onCompletableAssembly)
focal_class.full_signature: public static void setOnCompletableAssembly(@Nullable Function<? super Completable, ? extends Completable> onCompletableAssembly)
focal_class.identifier: setOnCompletableAssembly
focal_class.modifiers: public static
focal_class.parameters: (@Nullable Function<? super Completable, ? extends Completable> onCompletableAssembly)
focal_class.return: void
focal_class.signature: void setOnCompletableAssembly(@Nullable Function<? super Completable, ? extends Completable> onCompletableAssembly)
focal_class.class_method_signature: RxJavaPlugins.setOnCompletableSubscribe(
              @Nullable BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe)
focal_class.full_signature: public static void setOnCompletableSubscribe(
              @Nullable BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe)
focal_class.identifier: setOnCompletableSubscribe
focal_class.modifiers: public static
focal_class.parameters: (
              @Nullable BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe)
focal_class.return: void
focal_class.signature: void setOnCompletableSubscribe(
              @Nullable BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe)
focal_class.class_method_signature: RxJavaPlugins.setOnFlowableAssembly(@Nullable Function<? super Flowable, ? extends Flowable> onFlowableAssembly)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnFlowableAssembly(@Nullable Function<? super Flowable, ? extends Flowable> onFlowableAssembly)
focal_class.identifier: setOnFlowableAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable Function<? super Flowable, ? extends Flowable> onFlowableAssembly)
focal_class.return: void
focal_class.signature: void setOnFlowableAssembly(@Nullable Function<? super Flowable, ? extends Flowable> onFlowableAssembly)
focal_class.class_method_signature: RxJavaPlugins.setOnMaybeAssembly(@Nullable Function<? super Maybe, ? extends Maybe> onMaybeAssembly)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnMaybeAssembly(@Nullable Function<? super Maybe, ? extends Maybe> onMaybeAssembly)
focal_class.identifier: setOnMaybeAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable Function<? super Maybe, ? extends Maybe> onMaybeAssembly)
focal_class.return: void
focal_class.signature: void setOnMaybeAssembly(@Nullable Function<? super Maybe, ? extends Maybe> onMaybeAssembly)
focal_class.class_method_signature: RxJavaPlugins.setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly)
focal_class.identifier: setOnConnectableFlowableAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly)
focal_class.return: void
focal_class.signature: void setOnConnectableFlowableAssembly(@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly)
focal_class.class_method_signature: RxJavaPlugins.setOnFlowableSubscribe(@Nullable BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> onFlowableSubscribe)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnFlowableSubscribe(@Nullable BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> onFlowableSubscribe)
focal_class.identifier: setOnFlowableSubscribe
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> onFlowableSubscribe)
focal_class.return: void
focal_class.signature: void setOnFlowableSubscribe(@Nullable BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> onFlowableSubscribe)
focal_class.class_method_signature: RxJavaPlugins.setOnMaybeSubscribe(@Nullable BiFunction<? super Maybe, MaybeObserver, ? extends MaybeObserver> onMaybeSubscribe)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnMaybeSubscribe(@Nullable BiFunction<? super Maybe, MaybeObserver, ? extends MaybeObserver> onMaybeSubscribe)
focal_class.identifier: setOnMaybeSubscribe
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable BiFunction<? super Maybe, MaybeObserver, ? extends MaybeObserver> onMaybeSubscribe)
focal_class.return: void
focal_class.signature: void setOnMaybeSubscribe(@Nullable BiFunction<? super Maybe, MaybeObserver, ? extends MaybeObserver> onMaybeSubscribe)
focal_class.class_method_signature: RxJavaPlugins.setOnObservableAssembly(@Nullable Function<? super Observable, ? extends Observable> onObservableAssembly)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnObservableAssembly(@Nullable Function<? super Observable, ? extends Observable> onObservableAssembly)
focal_class.identifier: setOnObservableAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable Function<? super Observable, ? extends Observable> onObservableAssembly)
focal_class.return: void
focal_class.signature: void setOnObservableAssembly(@Nullable Function<? super Observable, ? extends Observable> onObservableAssembly)
focal_class.class_method_signature: RxJavaPlugins.setOnConnectableObservableAssembly(@Nullable Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnConnectableObservableAssembly(@Nullable Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly)
focal_class.identifier: setOnConnectableObservableAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly)
focal_class.return: void
focal_class.signature: void setOnConnectableObservableAssembly(@Nullable Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly)
focal_class.class_method_signature: RxJavaPlugins.setOnObservableSubscribe(
              @Nullable BiFunction<? super Observable, ? super Observer, ? extends Observer> onObservableSubscribe)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnObservableSubscribe(
              @Nullable BiFunction<? super Observable, ? super Observer, ? extends Observer> onObservableSubscribe)
focal_class.identifier: setOnObservableSubscribe
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (
              @Nullable BiFunction<? super Observable, ? super Observer, ? extends Observer> onObservableSubscribe)
focal_class.return: void
focal_class.signature: void setOnObservableSubscribe(
              @Nullable BiFunction<? super Observable, ? super Observer, ? extends Observer> onObservableSubscribe)
focal_class.class_method_signature: RxJavaPlugins.setOnSingleAssembly(@Nullable Function<? super Single, ? extends Single> onSingleAssembly)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnSingleAssembly(@Nullable Function<? super Single, ? extends Single> onSingleAssembly)
focal_class.identifier: setOnSingleAssembly
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable Function<? super Single, ? extends Single> onSingleAssembly)
focal_class.return: void
focal_class.signature: void setOnSingleAssembly(@Nullable Function<? super Single, ? extends Single> onSingleAssembly)
focal_class.class_method_signature: RxJavaPlugins.setOnSingleSubscribe(@Nullable BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> onSingleSubscribe)
focal_class.full_signature: @SuppressWarnings("rawtypes") public static void setOnSingleSubscribe(@Nullable BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> onSingleSubscribe)
focal_class.identifier: setOnSingleSubscribe
focal_class.modifiers: @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> onSingleSubscribe)
focal_class.return: void
focal_class.signature: void setOnSingleSubscribe(@Nullable BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> onSingleSubscribe)
focal_class.class_method_signature: RxJavaPlugins.onSubscribe(@NonNull Flowable<T> source, @NonNull Subscriber<? super T> subscriber)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static Subscriber<? super T> onSubscribe(@NonNull Flowable<T> source, @NonNull Subscriber<? super T> subscriber)
focal_class.identifier: onSubscribe
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Flowable<T> source, @NonNull Subscriber<? super T> subscriber)
focal_class.return: Subscriber<? super T>
focal_class.signature: Subscriber<? super T> onSubscribe(@NonNull Flowable<T> source, @NonNull Subscriber<? super T> subscriber)
focal_class.class_method_signature: RxJavaPlugins.onSubscribe(@NonNull Observable<T> source, @NonNull Observer<? super T> observer)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static Observer<? super T> onSubscribe(@NonNull Observable<T> source, @NonNull Observer<? super T> observer)
focal_class.identifier: onSubscribe
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Observable<T> source, @NonNull Observer<? super T> observer)
focal_class.return: Observer<? super T>
focal_class.signature: Observer<? super T> onSubscribe(@NonNull Observable<T> source, @NonNull Observer<? super T> observer)
focal_class.class_method_signature: RxJavaPlugins.onSubscribe(@NonNull Single<T> source, @NonNull SingleObserver<? super T> observer)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static SingleObserver<? super T> onSubscribe(@NonNull Single<T> source, @NonNull SingleObserver<? super T> observer)
focal_class.identifier: onSubscribe
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Single<T> source, @NonNull SingleObserver<? super T> observer)
focal_class.return: SingleObserver<? super T>
focal_class.signature: SingleObserver<? super T> onSubscribe(@NonNull Single<T> source, @NonNull SingleObserver<? super T> observer)
focal_class.class_method_signature: RxJavaPlugins.onSubscribe(@NonNull Completable source, @NonNull CompletableObserver observer)
focal_class.full_signature: @NonNull public static CompletableObserver onSubscribe(@NonNull Completable source, @NonNull CompletableObserver observer)
focal_class.identifier: onSubscribe
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Completable source, @NonNull CompletableObserver observer)
focal_class.return: CompletableObserver
focal_class.signature: CompletableObserver onSubscribe(@NonNull Completable source, @NonNull CompletableObserver observer)
focal_class.class_method_signature: RxJavaPlugins.onSubscribe(@NonNull Maybe<T> source, @NonNull MaybeObserver<? super T> subscriber)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static MaybeObserver<? super T> onSubscribe(@NonNull Maybe<T> source, @NonNull MaybeObserver<? super T> subscriber)
focal_class.identifier: onSubscribe
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Maybe<T> source, @NonNull MaybeObserver<? super T> subscriber)
focal_class.return: MaybeObserver<? super T>
focal_class.signature: MaybeObserver<? super T> onSubscribe(@NonNull Maybe<T> source, @NonNull MaybeObserver<? super T> subscriber)
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull Maybe<T> source)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static Maybe<T> onAssembly(@NonNull Maybe<T> source)
focal_class.identifier: onAssembly
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Maybe<T> source)
focal_class.return: Maybe<T>
focal_class.signature: Maybe<T> onAssembly(@NonNull Maybe<T> source)
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull Flowable<T> source)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static Flowable<T> onAssembly(@NonNull Flowable<T> source)
focal_class.identifier: onAssembly
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Flowable<T> source)
focal_class.return: Flowable<T>
focal_class.signature: Flowable<T> onAssembly(@NonNull Flowable<T> source)
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull ConnectableFlowable<T> source)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static ConnectableFlowable<T> onAssembly(@NonNull ConnectableFlowable<T> source)
focal_class.identifier: onAssembly
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull ConnectableFlowable<T> source)
focal_class.return: ConnectableFlowable<T>
focal_class.signature: ConnectableFlowable<T> onAssembly(@NonNull ConnectableFlowable<T> source)
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull Observable<T> source)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static Observable<T> onAssembly(@NonNull Observable<T> source)
focal_class.identifier: onAssembly
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Observable<T> source)
focal_class.return: Observable<T>
focal_class.signature: Observable<T> onAssembly(@NonNull Observable<T> source)
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull ConnectableObservable<T> source)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static ConnectableObservable<T> onAssembly(@NonNull ConnectableObservable<T> source)
focal_class.identifier: onAssembly
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull ConnectableObservable<T> source)
focal_class.return: ConnectableObservable<T>
focal_class.signature: ConnectableObservable<T> onAssembly(@NonNull ConnectableObservable<T> source)
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull Single<T> source)
focal_class.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static Single<T> onAssembly(@NonNull Single<T> source)
focal_class.identifier: onAssembly
focal_class.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull Single<T> source)
focal_class.return: Single<T>
focal_class.signature: Single<T> onAssembly(@NonNull Single<T> source)
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull Completable source)
focal_class.full_signature: @NonNull public static Completable onAssembly(@NonNull Completable source)
focal_class.identifier: onAssembly
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull Completable source)
focal_class.return: Completable
focal_class.signature: Completable onAssembly(@NonNull Completable source)
focal_class.class_method_signature: RxJavaPlugins.setOnParallelAssembly(@Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable> handler)
focal_class.full_signature: @Beta @SuppressWarnings("rawtypes") public static void setOnParallelAssembly(@Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable> handler)
focal_class.identifier: setOnParallelAssembly
focal_class.modifiers: @Beta @SuppressWarnings("rawtypes") public static
focal_class.parameters: (@Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable> handler)
focal_class.return: void
focal_class.signature: void setOnParallelAssembly(@Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable> handler)
focal_class.class_method_signature: RxJavaPlugins.getOnParallelAssembly()
focal_class.full_signature: @Beta @SuppressWarnings("rawtypes") @Nullable public static Function<? super ParallelFlowable, ? extends ParallelFlowable> getOnParallelAssembly()
focal_class.identifier: getOnParallelAssembly
focal_class.modifiers: @Beta @SuppressWarnings("rawtypes") @Nullable public static
focal_class.parameters: ()
focal_class.return: Function<? super ParallelFlowable, ? extends ParallelFlowable>
focal_class.signature: Function<? super ParallelFlowable, ? extends ParallelFlowable> getOnParallelAssembly()
focal_class.class_method_signature: RxJavaPlugins.onAssembly(@NonNull ParallelFlowable<T> source)
focal_class.full_signature: @Beta @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static ParallelFlowable<T> onAssembly(@NonNull ParallelFlowable<T> source)
focal_class.identifier: onAssembly
focal_class.modifiers: @Beta @SuppressWarnings({ "rawtypes", "unchecked" }) @NonNull public static
focal_class.parameters: (@NonNull ParallelFlowable<T> source)
focal_class.return: ParallelFlowable<T>
focal_class.signature: ParallelFlowable<T> onAssembly(@NonNull ParallelFlowable<T> source)
focal_class.class_method_signature: RxJavaPlugins.onBeforeBlocking()
focal_class.full_signature: public static boolean onBeforeBlocking()
focal_class.identifier: onBeforeBlocking
focal_class.modifiers: public static
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean onBeforeBlocking()
focal_class.class_method_signature: RxJavaPlugins.setOnBeforeBlocking(@Nullable BooleanSupplier handler)
focal_class.full_signature: public static void setOnBeforeBlocking(@Nullable BooleanSupplier handler)
focal_class.identifier: setOnBeforeBlocking
focal_class.modifiers: public static
focal_class.parameters: (@Nullable BooleanSupplier handler)
focal_class.return: void
focal_class.signature: void setOnBeforeBlocking(@Nullable BooleanSupplier handler)
focal_class.class_method_signature: RxJavaPlugins.getOnBeforeBlocking()
focal_class.full_signature: @Nullable public static BooleanSupplier getOnBeforeBlocking()
focal_class.identifier: getOnBeforeBlocking
focal_class.modifiers: @Nullable public static
focal_class.parameters: ()
focal_class.return: BooleanSupplier
focal_class.signature: BooleanSupplier getOnBeforeBlocking()
focal_class.class_method_signature: RxJavaPlugins.createComputationScheduler(@NonNull ThreadFactory threadFactory)
focal_class.full_signature: @NonNull public static Scheduler createComputationScheduler(@NonNull ThreadFactory threadFactory)
focal_class.identifier: createComputationScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull ThreadFactory threadFactory)
focal_class.return: Scheduler
focal_class.signature: Scheduler createComputationScheduler(@NonNull ThreadFactory threadFactory)
focal_class.class_method_signature: RxJavaPlugins.createIoScheduler(@NonNull ThreadFactory threadFactory)
focal_class.full_signature: @NonNull public static Scheduler createIoScheduler(@NonNull ThreadFactory threadFactory)
focal_class.identifier: createIoScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull ThreadFactory threadFactory)
focal_class.return: Scheduler
focal_class.signature: Scheduler createIoScheduler(@NonNull ThreadFactory threadFactory)
focal_class.class_method_signature: RxJavaPlugins.createNewThreadScheduler(@NonNull ThreadFactory threadFactory)
focal_class.full_signature: @NonNull public static Scheduler createNewThreadScheduler(@NonNull ThreadFactory threadFactory)
focal_class.identifier: createNewThreadScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull ThreadFactory threadFactory)
focal_class.return: Scheduler
focal_class.signature: Scheduler createNewThreadScheduler(@NonNull ThreadFactory threadFactory)
focal_class.class_method_signature: RxJavaPlugins.createSingleScheduler(@NonNull ThreadFactory threadFactory)
focal_class.full_signature: @NonNull public static Scheduler createSingleScheduler(@NonNull ThreadFactory threadFactory)
focal_class.identifier: createSingleScheduler
focal_class.modifiers: @NonNull public static
focal_class.parameters: (@NonNull ThreadFactory threadFactory)
focal_class.return: Scheduler
focal_class.signature: Scheduler createSingleScheduler(@NonNull ThreadFactory threadFactory)
focal_class.class_method_signature: RxJavaPlugins.apply(@NonNull Function<T, R> f, @NonNull T t)
focal_class.full_signature: @NonNull static R apply(@NonNull Function<T, R> f, @NonNull T t)
focal_class.identifier: apply
focal_class.modifiers: @NonNull static
focal_class.parameters: (@NonNull Function<T, R> f, @NonNull T t)
focal_class.return: R
focal_class.signature: R apply(@NonNull Function<T, R> f, @NonNull T t)
focal_class.class_method_signature: RxJavaPlugins.apply(@NonNull BiFunction<T, U, R> f, @NonNull T t, @NonNull U u)
focal_class.full_signature: @NonNull static R apply(@NonNull BiFunction<T, U, R> f, @NonNull T t, @NonNull U u)
focal_class.identifier: apply
focal_class.modifiers: @NonNull static
focal_class.parameters: (@NonNull BiFunction<T, U, R> f, @NonNull T t, @NonNull U u)
focal_class.return: R
focal_class.signature: R apply(@NonNull BiFunction<T, U, R> f, @NonNull T t, @NonNull U u)
focal_class.class_method_signature: RxJavaPlugins.callRequireNonNull(@NonNull Callable<Scheduler> s)
focal_class.full_signature: @NonNull static Scheduler callRequireNonNull(@NonNull Callable<Scheduler> s)
focal_class.identifier: callRequireNonNull
focal_class.modifiers: @NonNull static
focal_class.parameters: (@NonNull Callable<Scheduler> s)
focal_class.return: Scheduler
focal_class.signature: Scheduler callRequireNonNull(@NonNull Callable<Scheduler> s)
focal_class.class_method_signature: RxJavaPlugins.applyRequireNonNull(@NonNull Function<? super Callable<Scheduler>, ? extends Scheduler> f, Callable<Scheduler> s)
focal_class.full_signature: @NonNull static Scheduler applyRequireNonNull(@NonNull Function<? super Callable<Scheduler>, ? extends Scheduler> f, Callable<Scheduler> s)
focal_class.identifier: applyRequireNonNull
focal_class.modifiers: @NonNull static
focal_class.parameters: (@NonNull Function<? super Callable<Scheduler>, ? extends Scheduler> f, Callable<Scheduler> s)
focal_class.return: Scheduler
focal_class.signature: Scheduler applyRequireNonNull(@NonNull Function<? super Callable<Scheduler>, ? extends Scheduler> f, Callable<Scheduler> s)
focal_class.class_method_signature: RxJavaPlugins.RxJavaPlugins()
focal_class.full_signature: private  RxJavaPlugins()
focal_class.identifier: RxJavaPlugins
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.signature:  RxJavaPlugins()
focal_method.body: static boolean isBug(Throwable error) {
          // user forgot to add the onError handler in subscribe
          if (error instanceof OnErrorNotImplementedException) {
              return true;
          }
          // the sender didn't honor the request amount
          // it's either due to an operator bug or concurrent onNext
          if (error instanceof MissingBackpressureException) {
              return true;
          }
          // general protocol violations
          // it's either due to an operator bug or concurrent onNext
          if (error instanceof IllegalStateException) {
              return true;
          }
          // nulls are generally not allowed
          // likely an operator bug or missing null-check
          if (error instanceof NullPointerException) {
              return true;
          }
          // bad arguments, likely invalid user input
          if (error instanceof IllegalArgumentException) {
              return true;
          }
          // Crash while handling an exception
          if (error instanceof CompositeException) {
              return true;
          }
          // everything else is probably due to lifecycle limits
          return false;
      }
focal_method.class_method_signature: RxJavaPlugins.isBug(Throwable error)
focal_method.full_signature: static boolean isBug(Throwable error)
focal_method.identifier: isBug
focal_method.modifiers: static
focal_method.parameters: (Throwable error)
focal_method.return: boolean
focal_method.signature: boolean isBug(Throwable error)