diff --git a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java index e5cdaab..585d373 100644 --- a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java +++ b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java @@ -21,5 +21,6 @@ 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()); + findViewById(R.id.error_btn).setOnClickListener(view -> rxProcess.error()); } } diff --git a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java index 874bf94..5306172 100644 --- a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java +++ b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java @@ -166,4 +166,11 @@ () -> System.out.println("完了") ); } + + /** + * エラーのみを通知する + */ + public void error() { + Flowable.error(new Exception("例外発生")).subscribe(new DebugSubscriber<>()); + } } diff --git a/app/src/main/res/layout/activity_main_java.xml b/app/src/main/res/layout/activity_main_java.xml index bf7fc00..5a00c5d 100644 --- a/app/src/main/res/layout/activity_main_java.xml +++ b/app/src/main/res/layout/activity_main_java.xml @@ -65,6 +65,15 @@ android:text="timer" app:layout_constraintStart_toStartOf="parent" app:layout_constraintTop_toBottomOf="@id/interval_btn" /> + +