From 3bda12d20c9b820531e9feebb7bcd89a35421bf7 Mon Sep 17 00:00:00 2001
From: Tomasz Lelek <tomasz.lelek@allegrogroup.com>
Date: Sat, 4 Feb 2017 17:00:22 +0100
Subject: [PATCH] BEAL-572 use same chedulers to be consistent

---
 .../java/com/baelding/rxjava/ColdObservableBackpressure.java    | 2 +-
 .../java/com/baelding/rxjava/HotObservableOnBackPressure.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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);