1. Qiita
  2. 投稿
  3. Android

[Android] RxJavaでズンドコ

  • 2
    いいね
  • 0
    コメント

前回の RxJSでズンドコ に引き続き、RxJava on Android でやってみました。

ズンドコキヨシとはなんぞや?という方はこちら ⇒ ズンドコキヨシまとめ

PublishSubject<String> subject = PublishSubject.create();

subject
        .doOnNext((aString) -> Log.i("ZunDoko", aString))
        .buffer(5, 1)
        .filter(aArray -> aArray.toString().equals("[ズン, ズン, ズン, ズン, ドコ]"))
        .take(1)
        .subscribe(aArray -> {
            Log.i("ZunDoko", "キ・ヨ・シ!");
            subject.onCompleted();
        });

while (!subject.hasCompleted()) {
    if (Math.random() > 0.5) {
        subject.onNext("ズン");
    } else {
        subject.onNext("ドコ");
    }
}

スクリーンショット 2016-03-19 15.25.21.png