from(this) -> nest()

benjchristensen · benjchristensen · commit 53e102d5182d · 2014-02-06T20:06:39.000-08:00
diff --git a/rxjava-core/src/main/java/rx/Observable.java b/rxjava-core/src/main/java/rx/Observable.java
@@ -7028,7 +7028,7 @@ public final Subscription subscribe(Subscriber<? super T> observer, Scheduler sc
      * @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#wiki-subscribeon">RxJava Wiki: subscribeOn()</a>
      */
     public final Observable<T> subscribeOn(Scheduler scheduler) {
-        return from(this).lift(new OperatorSubscribeOn<T>(scheduler));
+        return nest().lift(new OperatorSubscribeOn<T>(scheduler));
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -7028,7 +7028,7 @@ public final Subscription subscribe(Subscriber<? super T> observer, Scheduler sc`
`7028`	`7028`	`* @see <a href="https://github.com/Netflix/RxJava/wiki/Observable-Utility-Operators#wiki-subscribeon">RxJava Wiki: subscribeOn()</a>`
`7029`	`7029`	`*/`
`7030`	`7030`	`public final Observable<T> subscribeOn(Scheduler scheduler) {`
`7031`		`- return from(this).lift(new OperatorSubscribeOn<T>(scheduler));`
	`7031`	`+ return nest().lift(new OperatorSubscribeOn<T>(scheduler));`
`7032`	`7032`	`}`
`7033`	`7033`
`7034`	`7034`	`/**`