walker_example.clj

user> (def p (make-pipe))
#'user/p
user> (put! p :a)
nil
user> (put! p :b)
nil
user> (def s1 (source-seq p))
#'user/s1
user> (def w (make-walker s1))
#'user/w
user> (def s2 (deref (:tail w)))
#'user/s2
user> (put! p :c)
nil
user> (put! p :d)
nil
user> (close! p)
nil
user> s1
(:a :b :c :d)
user> s2
(:c :d)