diff --git a/rxjava/src/main/java/com/baelding/rxjava/ColdObservableBackpressure.java b/rxjava/src/main/java/com/baelding/rxjava/ColdObservableBackpressure.java
index cebc2d35f6..b0be29957d 100644
--- a/rxjava/src/main/java/com/baelding/rxjava/ColdObservableBackpressure.java
+++ b/rxjava/src/main/java/com/baelding/rxjava/ColdObservableBackpressure.java
@@ -9,7 +9,7 @@ public class ColdObservableBackPressure {
     public static void main(String[] args) throws InterruptedException {
         Observable.range(1, 1_000_000)
                 .observeOn(Schedulers.computation())
-                .subscribe(v -> ComputeFunction.compute(v), Throwable::printStackTrace);
+                .subscribe(ComputeFunction::compute);
 
         Thread.sleep(10_000);
 
diff --git a/rxjava/src/main/java/com/baelding/rxjava/HotObservableOnBackPressure.java b/rxjava/src/main/java/com/baelding/rxjava/HotObservableOnBackPressure.java
index bf86312fff..124ee64d0b 100644
--- a/rxjava/src/main/java/com/baelding/rxjava/HotObservableOnBackPressure.java
+++ b/rxjava/src/main/java/com/baelding/rxjava/HotObservableOnBackPressure.java
@@ -18,7 +18,7 @@ public class HotObservableOnBackPressure {
 
         Observable.range(1, 1_000_000)
                 .onBackpressureDrop()
-                .observeOn(Schedulers.io())
+                .observeOn(Schedulers.computation())
                 .doOnNext(ComputeFunction::compute)
                 .subscribe(v -> {
                 }, Throwable::printStackTrace);