Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ;; This works
- (defn subscribe* [http-url path query-map f]
- (with-open [client (client/create-client)]
- (let [response (stream-seq client http-url path query-map)]
- (doseq [content (client/string response)]
- (doseq [line (re-seq #".+\r\n" content)]
- (let [record (json/read-json line)]
- (f record)))))))
- ;; But has to be called like this:
- (subscribe rexx yy zz #(println %))
- ;; Want to be able to get a seq back instead:
- (doseq [s (subscribe-seq xx yy zz)]
- (println s))
- ;; How can I fold in the multiple lazy-seq's into a single (subscribe-seq ??
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement