Hy on RxPy

gistfile1.hy

;; Adapted from https://github.com/ReactiveX/RxPY/blob/master/examples/konamicode/konamicode.py

(import [rx.subjects [Subject]])

(setv codes [:up :up :down :down :left :right :left :right :b :a])
(setv subject (Subject))

(setv query (-> (.window_with_count subject 10 1)
                (.select-many (fn [win] (.sequence-equal win codes)))
                (.filter (fn [equal] equal))))

(.subscribe query (fn [x] (print "Konami!")))

(.on-next subject :up)
(.on-next subject :up)
(.on-next subject :down)
(.on-next subject :down)
(.on-next subject :left)
(.on-next subject :right)
(.on-next subject :left)
(.on-next subject :right)
(.on-next subject :b)
(.on-next subject :a)

When the correct sequence of codes is fed into subject, "Konami!" will be printed.