kiyoshi-rxjs.js

var Rx = require('rx');
var Observable = Rx.Observable;

var match = ["ズン", "ズン", "ズン", "ズン", "ドコ"];

Observable.create((obs) => {
    obs.onNext(Math.random() > 0.5 ? "ズン" : "ドコ");
    obs.onCompleted();
})
    .do((e) => { console.log(e); })
    .repeat()
    .windowWithCount(5, 1)
    .selectMany((e) => {
        return e.zip(Observable.from(match))
            .scan((prev, current) => {
                return prev && (current[0] === current[1])
            }, true)
            .last()
    })
    .first((e) => { return e; })
    .subscribe((e) => {
        console.log("キヨシ！");
    });

output

$ node kiyoshi-rxjs.js
ズン
ズン
ドコ
ドコ
ズン
ズン
ドコ
ズン
ドコ
ズン
ドコ
ドコ
ズン
ズン
ドコ
ズン
ズン
ズン
ズン
ドコ
キヨシ！