async-ctx.clj

;; using
;; https://github.com/dimovich/fressian-handlers/blob/caching/src/fressian/handlers.clj

(require '[fressian.handlers :as fh]
         '[clojure.data.fressian :as fres]
         '[clojure.core.async :as async]
         '[clojure.java.io :as io])


(def ch (async/chan))

(async/go
  (with-open [out (io/output-stream "test.fress")]
    (with-open [wrt (fres/create-writer out :handlers (fh/get-write-handler-lookup))]
      (loop []
        (when-let [v (async/<! ch)]
          (fres/write-object wrt v)
          (recur))))))


(async/>!! ch [1 2 3])