diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java index e017088b2a..746362ca78 100644 --- a/rxjava-core/src/main/java/rx/Observable.java +++ b/rxjava-core/src/main/java/rx/Observable.java @@ -174,7 +174,7 @@ protected Observable(OnSubscribe f) { this.onSubscribe = f; } - private final RxJavaObservableExecutionHook hook = RxJavaPlugins.getInstance().getObservableExecutionHook(); + private static final RxJavaObservableExecutionHook hook = RxJavaPlugins.getInstance().getObservableExecutionHook(); /** * Returns an Observable that will execute the specified function when a {@link Subscriber} subscribes to @@ -201,7 +201,7 @@ protected Observable(OnSubscribe f) { * @see MSDN: Observable.Create */ public final static Observable create(OnSubscribe f) { - return new Observable(f); + return new Observable(hook.onCreate(f)); } /**