Skip to content

Commit 7227482

Browse files
Merge pull request #1092 from benjchristensen/ObservableExecutionHook-onCreate
Restore ObservableExecutionHook.onCreate
2 parents 3161910 + 12723ef commit 7227482

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Diff for: rxjava-core/src/main/java/rx/Observable.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ protected Observable(OnSubscribe<T> f) {
174174
this.onSubscribe = f;
175175
}
176176

177-
private final RxJavaObservableExecutionHook hook = RxJavaPlugins.getInstance().getObservableExecutionHook();
177+
private static final RxJavaObservableExecutionHook hook = RxJavaPlugins.getInstance().getObservableExecutionHook();
178178

179179
/**
180180
* Returns an Observable that will execute the specified function when a {@link Subscriber} subscribes to
@@ -201,7 +201,7 @@ protected Observable(OnSubscribe<T> f) {
201201
* @see <a href="http://msdn.microsoft.com/en-us/library/system.reactive.linq.observable.create.aspx">MSDN: Observable.Create</a>
202202
*/
203203
public final static <T> Observable<T> create(OnSubscribe<T> f) {
204-
return new Observable<T>(f);
204+
return new Observable<T>(hook.onCreate(f));
205205
}
206206

207207
/**

0 commit comments

Comments
 (0)