   (:require
    [plumbing.core :refer :all]
    [manifold.deferred :as d]
+   [manifold.stream :as s]
    [qbits.hayt :as h]
    [er-cassandra.key :refer [make-sequential extract-key-equality-clause]]
    [er-cassandra.session :as session])

    opts)))

(defn select-buffered
  "select records"

  ([^Session session table key record-or-key-value]
   (select session table key record-or-key-value {}))

    table
    key
    record-or-key-value
    opts]
   (session/execute
    session
    (select-statement table key record-or-key-value
