diff --git a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java
index ebbadd8..e2f3b3e 100644
--- a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java
+++ b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java
@@ -36,7 +36,7 @@
 
         flowable
                 // Subscriberの処理を別のスレッドで行うようにする
-                .subscribeOn(Schedulers.computation())
+                .observeOn(Schedulers.computation())
                 .subscribe(new Subscriber<String>() {
 
                     // データ数のリクエストおよび購読の解除を行うオブジェクト