diff --git a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java index e775591..37e4b67 100644 --- a/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java +++ b/app/src/main/java/org/ntlab/developrx/JavaMainActivity.java @@ -15,9 +15,8 @@ setContentView(R.layout.activity_main_java); findViewById(R.id.flowable_btn).setOnClickListener(view -> rxProcess.flowableReactiveStreams()); - findViewById(R.id.observable_btn).setOnClickListener(view -> rxProcess.observable()); - findViewById(R.id.just_btn).setOnClickListener(view -> rxProcess.just()); + findViewById(R.id.fromarray_btn).setOnClickListener(view -> rxProcess.fromArray()); } } diff --git a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java index 3f8dd20..a2e5dd2 100644 --- a/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java +++ b/app/src/main/java/org/ntlab/developrx/JavaRxProcess.java @@ -124,8 +124,16 @@ * 引数のデータを通知するFLowableを作成 * 引数は10個まで */ - public void just(){ - Flowable flowable = Flowable.just("A","B","C","D","E","F","G","H","I","J"); + public void just() { + Flowable flowable = Flowable.just("A", "B", "C", "D", "E", "F", "G", "H", "I", "J"); + flowable.subscribe(new DebugSubscriber<>()); + } + + /** + * 引数のデータを通知するFlowableを作成 + */ + public void fromArray() { + Flowable flowable = Flowable.fromArray("A", "B", "C", "D", "E", "F", "G", "H", "I", "J", "K"); flowable.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 bb4850c..97c0faf 100644 --- a/app/src/main/res/layout/activity_main_java.xml +++ b/app/src/main/res/layout/activity_main_java.xml @@ -33,6 +33,14 @@ android:text="just" app:layout_constraintStart_toStartOf="parent" app:layout_constraintTop_toBottomOf="@id/observable_btn" /> + +