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: @SuppressWarnings({ "rawtypes" })
      @Test
      public void lockdown() throws Exception {
          RxJavaPlugins.reset();
          RxJavaPlugins.lockdown();
          try {
              assertTrue(RxJavaPlugins.isLockdown());
              Consumer a1 = Functions.emptyConsumer();
              Callable f0 = new Callable() {
                  @Override
                  public Object call() {
                      return null;
                  }
              };
              Function f1 = Functions.identity();
              BiFunction f2 = new BiFunction() {
                  @Override
                  public Object apply(Object t1, Object t2) {
                      return t2;
                  }
              };
  
              BooleanSupplier bs = new BooleanSupplier() {
                  @Override
                  public boolean getAsBoolean() throws Exception {
                      return true;
                  }
              };
  
              for (Method m : RxJavaPlugins.class.getMethods()) {
                  if (m.getName().startsWith("set")) {
  
                      Method getter;
  
                      Class<?> paramType = m.getParameterTypes()[0];
  
                      if (paramType == Boolean.TYPE) {
                          getter = RxJavaPlugins.class.getMethod("is" + m.getName().substring(3));
                      } else {
                          getter = RxJavaPlugins.class.getMethod("get" + m.getName().substring(3));
                      }
  
                      Object before = getter.invoke(null);
  
                      try {
                          if (paramType.isAssignableFrom(Boolean.TYPE)) {
                              m.invoke(null, true);
                          } else
                          if (paramType.isAssignableFrom(Callable.class)) {
                              m.invoke(null, f0);
                          } else
                          if (paramType.isAssignableFrom(Function.class)) {
                              m.invoke(null, f1);
                          } else
                          if (paramType.isAssignableFrom(Consumer.class)) {
                              m.invoke(null, a1);
                          } else
                          if (paramType.isAssignableFrom(BooleanSupplier.class)) {
                              m.invoke(null, bs);
                          } else {
                              m.invoke(null, f2);
                          }
                          fail("Should have thrown InvocationTargetException(IllegalStateException)");
                      } catch (InvocationTargetException ex) {
                          if (ex.getCause() instanceof IllegalStateException) {
                              assertEquals("Plugins can't be changed anymore",ex.getCause().getMessage());
                          } else {
                              fail("Should have thrown InvocationTargetException(IllegalStateException)");
                          }
                      }
  
                      Object after = getter.invoke(null);
  
                      if (paramType.isPrimitive()) {
                          assertEquals(m.toString(), before, after);
                      } else {
                          assertSame(m.toString(), before, after);
                      }
                  }
              }
  
  //            Object o1 = RxJavaPlugins.getOnObservableCreate();
  //            Object o2 = RxJavaPlugins.getOnSingleCreate();
  //            Object o3 = RxJavaPlugins.getOnCompletableCreate();
  //
  //            RxJavaPlugins.enableAssemblyTracking();
  //            RxJavaPlugins.clearAssemblyTracking();
  //            RxJavaPlugins.resetAssemblyTracking();
  //
  //
  //            assertSame(o1, RxJavaPlugins.getOnObservableCreate());
  //            assertSame(o2, RxJavaPlugins.getOnSingleCreate());
  //            assertSame(o3, RxJavaPlugins.getOnCompletableCreate());
  
          } finally {
              RxJavaPlugins.unlock();
              RxJavaPlugins.reset();
              assertFalse(RxJavaPlugins.isLockdown());
          }
      }
test_case.class_method_signature: RxJavaPluginsTest.lockdown()
test_case.full_signature: @SuppressWarnings({ "rawtypes" }) @Test public void lockdown()
test_case.identifier: lockdown
test_case.invocations: reset lockdown assertTrue isLockdown emptyConsumer identity getMethods startsWith getName getParameterTypes getMethod substring getName getMethod substring getName invoke isAssignableFrom invoke isAssignableFrom invoke isAssignableFrom invoke isAssignableFrom invoke isAssignableFrom invoke invoke fail getCause assertEquals getMessage getCause fail invoke isPrimitive assertEquals toString assertSame toString unlock reset assertFalse isLockdown
test_case.modifiers: @SuppressWarnings({ "rawtypes" }) @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void lockdown()
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: public static void lockdown() {
          lockdown = true;
      }
focal_method.class_method_signature: RxJavaPlugins.lockdown()
focal_method.full_signature: public static void lockdown()
focal_method.identifier: lockdown
focal_method.modifiers: public static
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void lockdown()