We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents e9c3a9c + 9dab629 commit c7366d3Copy full SHA for c7366d3
rxjava-core/src/main/java/rx/Observable.java
@@ -206,7 +206,7 @@ protected Observable(OnSubscribe<T> f) {
206
* @see <a href="http://msdn.microsoft.com/en-us/library/system.reactive.linq.observable.create.aspx">MSDN: Observable.Create</a>
207
*/
208
public final static <T> Observable<T> create(OnSubscribe<T> f) {
209
- return new Observable<T>(f);
+ return new Observable<T>(hook.onCreate(f));
210
}
211
212
/**
0 commit comments