diff --git a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java
index 939aebb..b5445ec 100644
--- a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java
+++ b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java
@@ -2,6 +2,9 @@
 
 import android.os.Bundle;
 import android.support.v7.app.AppCompatActivity;
+import android.widget.SeekBar;
+
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by matsumoto_k on 2017/11/11.
@@ -27,5 +30,27 @@
         findViewById(R.id.flatmap_1_btn).setOnClickListener(view -> rxProcess.flatmap1());
         findViewById(R.id.flatmap_2_btn).setOnClickListener(view -> rxProcess.flatmap2());
         findViewById(R.id.meeting_btn).setOnClickListener(view -> rxProcess.meetingTest());
+        SeekBar seekBar = findViewById(R.id.seek_bar);
+        seekBar.setMax(1000);
+        seekBar.setOnSeekBarChangeListener(new SeekBar.OnSeekBarChangeListener() {
+            @Override
+            public void onProgressChanged(SeekBar seekBar, int progress, boolean fromUser) {
+                rxProcess.getPublishSubject().onNext(progress);
+            }
+
+            @Override
+            public void onStartTrackingTouch(SeekBar seekBar) {
+
+            }
+
+            @Override
+            public void onStopTrackingTouch(SeekBar seekBar) {
+
+            }
+        });
+
+        rxProcess.getPublishSubject()
+                .throttleLast(500, TimeUnit.MILLISECONDS)
+                .subscribe(progress -> System.out.println(progress));
     }
 }
diff --git a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java
index 95fb78b..5ea8bf2 100644
--- a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java
+++ b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java
@@ -16,6 +16,7 @@
 import io.reactivex.disposables.Disposable;
 import io.reactivex.processors.PublishProcessor;
 import io.reactivex.schedulers.Schedulers;
+import io.reactivex.subjects.PublishSubject;
 
 /**
  * Created by matsumoto_k on 2017/11/11.
@@ -23,6 +24,8 @@
 
 public class JavaRxProcess {
 
+    private PublishSubject<Integer> publishSubject = null;
+
     /**
      * Flowable (Reactive Streams対応)
      */
@@ -246,4 +249,11 @@
             }
         }).start();
     }
+
+    public PublishSubject<Integer> getPublishSubject() {
+        if (publishSubject == null) {
+            publishSubject = PublishSubject.create();
+        }
+        return publishSubject;
+    }
 }
diff --git a/app/src/main/res/layout/activity_main_java.xml b/app/src/main/res/layout/activity_main_java.xml
index 1c93d9f..c2da997 100644
--- a/app/src/main/res/layout/activity_main_java.xml
+++ b/app/src/main/res/layout/activity_main_java.xml
@@ -114,6 +114,13 @@
             app:layout_constraintStart_toStartOf="parent"
             app:layout_constraintTop_toBottomOf="@id/flatmap_2_btn" />
 
+        <SeekBar
+            android:id="@+id/seek_bar"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            app:layout_constraintStart_toStartOf="parent"
+            app:layout_constraintTop_toBottomOf="@id/meeting_btn" />
+
     </android.support.constraint.ConstraintLayout>
 
 </ScrollView>