db.clj

(defrecord DatascriptS3Db [bucket key-name schema conn-ch conn]
  component/Lifecycle
  (start [this]
    (let [conn-ch* (chan 1 (map (s3-obj->conn schema)))]
      (pipe (u/get-obj-ch bucket key-name) conn-ch*)
      (assoc this :conn-ch (go-loop
                               (if conn
                                 conn
                                 (<! conn-ch*))))))
  (stop [this]
    (-> this
        (dissoc :conn-ch))))