first-n

first-n.clj

(defn limited-output
  [keywords-str limit]
  (let [tweets-tap (tweets-new)
        urls-tap (short-urls)
        jdbc-sink db/jdbc-tap]
    (?- (stdout)
        (c/first-n
         (<- [ ?args ]
             ; query
         limit))))