@Test public void testObservableExecutionHookDefaultImpl() { RxJavaPlugins p = new RxJavaPlugins(); RxJavaObservableExecutionHook impl = p.getObservableExecutionHook(); assertTrue(impl instanceof RxJavaObservableExecutionHookDefault); }
public RxJavaObservableExecutionHook getObservableExecutionHook() { if (observableExecutionHook.get() == null) { Object impl = getPluginImplementationViaProperty(RxJavaObservableExecutionHook.class); if (impl == null) { observableExecutionHook.compareAndSet(null, RxJavaObservableExecutionHookDefault.getInstance()); } else { observableExecutionHook.compareAndSet(null, (RxJavaObservableExecutionHook) impl); } } return observableExecutionHook.get(); }
RxJavaPlugins { public RxJavaObservableExecutionHook getObservableExecutionHook() { if (observableExecutionHook.get() == null) { Object impl = getPluginImplementationViaProperty(RxJavaObservableExecutionHook.class); if (impl == null) { observableExecutionHook.compareAndSet(null, RxJavaObservableExecutionHookDefault.getInstance()); } else { observableExecutionHook.compareAndSet(null, (RxJavaObservableExecutionHook) impl); } } return observableExecutionHook.get(); } }
RxJavaPlugins { public RxJavaObservableExecutionHook getObservableExecutionHook() { if (observableExecutionHook.get() == null) { Object impl = getPluginImplementationViaProperty(RxJavaObservableExecutionHook.class); if (impl == null) { observableExecutionHook.compareAndSet(null, RxJavaObservableExecutionHookDefault.getInstance()); } else { observableExecutionHook.compareAndSet(null, (RxJavaObservableExecutionHook) impl); } } return observableExecutionHook.get(); } RxJavaPlugins(); }
RxJavaPlugins { public RxJavaObservableExecutionHook getObservableExecutionHook() { if (observableExecutionHook.get() == null) { Object impl = getPluginImplementationViaProperty(RxJavaObservableExecutionHook.class); if (impl == null) { observableExecutionHook.compareAndSet(null, RxJavaObservableExecutionHookDefault.getInstance()); } else { observableExecutionHook.compareAndSet(null, (RxJavaObservableExecutionHook) impl); } } return observableExecutionHook.get(); } RxJavaPlugins(); static RxJavaPlugins getInstance(); RxJavaErrorHandler getErrorHandler(); void registerErrorHandler(RxJavaErrorHandler impl); RxJavaObservableExecutionHook getObservableExecutionHook(); void registerObservableExecutionHook(RxJavaObservableExecutionHook impl); }
RxJavaPlugins { public RxJavaObservableExecutionHook getObservableExecutionHook() { if (observableExecutionHook.get() == null) { Object impl = getPluginImplementationViaProperty(RxJavaObservableExecutionHook.class); if (impl == null) { observableExecutionHook.compareAndSet(null, RxJavaObservableExecutionHookDefault.getInstance()); } else { observableExecutionHook.compareAndSet(null, (RxJavaObservableExecutionHook) impl); } } return observableExecutionHook.get(); } RxJavaPlugins(); static RxJavaPlugins getInstance(); RxJavaErrorHandler getErrorHandler(); void registerErrorHandler(RxJavaErrorHandler impl); RxJavaObservableExecutionHook getObservableExecutionHook(); void registerObservableExecutionHook(RxJavaObservableExecutionHook impl);  }