diff --git a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java index bce174b..e5cdaab 100644 --- a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java +++ b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java @@ -20,5 +20,6 @@ findViewById(R.id.fromarray_btn).setOnClickListener(view -> rxProcess.fromArray()); findViewById(R.id.range_btn).setOnClickListener(view -> rxProcess.range()); findViewById(R.id.interval_btn).setOnClickListener(view -> rxProcess.interval()); + findViewById(R.id.timer_btn).setOnClickListener(view -> rxProcess.timer()); } } diff --git a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java index af1465e..874bf94 100644 --- a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java +++ b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java @@ -154,4 +154,16 @@ Flowable flowable = Flowable.interval(1000L, TimeUnit.MILLISECONDS).take(5); flowable.subscribe(data -> System.out.println(ThreadUtil.getCurrentThreadName() + ": " + System.currentTimeMillis() + ": " + "data = " + data)); } + + /** + * 指定時間後に0を通知する + */ + public void timer() { + Flowable flowable = Flowable.timer(1000, TimeUnit.MILLISECONDS); + flowable.subscribe( + data -> System.out.println(ThreadUtil.getCurrentThreadName() + ": data = " + data), + error -> System.out.println("エラー = " + error), + () -> System.out.println("完了") + ); + } } diff --git a/app/src/main/res/layout/activity_main_java.xml b/app/src/main/res/layout/activity_main_java.xml index bfe943e..bf7fc00 100644 --- a/app/src/main/res/layout/activity_main_java.xml +++ b/app/src/main/res/layout/activity_main_java.xml @@ -57,6 +57,14 @@ android:text="interval" app:layout_constraintStart_toStartOf="parent" app:layout_constraintTop_toBottomOf="@id/range_btn" /> + +