Skip to content

Commit

Permalink
Reconnecting ObservableExecutionHook.onCreate
Browse files Browse the repository at this point in the history
Somehow this got lost in the refactorings over the past few weeks.
  • Loading branch information
benjchristensen committed Apr 25, 2014
1 parent 3161910 commit 12723ef
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions rxjava-core/src/main/java/rx/Observable.java
Original file line number Diff line number Diff line change
Expand Up @@ -174,7 +174,7 @@ protected Observable(OnSubscribe<T> 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
Expand All @@ -201,7 +201,7 @@ protected Observable(OnSubscribe<T> f) {
* @see <a href="http://msdn.microsoft.com/en-us/library/system.reactive.linq.observable.create.aspx">MSDN: Observable.Create</a>
*/
public final static <T> Observable<T> create(OnSubscribe<T> f) {
return new Observable<T>(f);
return new Observable<T>(hook.onCreate(f));
}

/**
Expand Down

0 comments on commit 12723ef

Please sign in to comment.