blocks until data is available on the trailers channel

twosigma · Apr 17, 2019 · ef581db · ef581db
1 parent 70109b5
commit ef581db
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/src/clj/qbits/jet/util.clj b/src/clj/qbits/jet/util.clj
@@ -42,10 +42,8 @@
 (defn trailers-ch->supplier
   [trailers-ch]
   (when trailers-ch
-    (let [trailers-atom (atom {})]
-      (async/go
-        (when-let [trailers (async/<! trailers-ch)]
-          (reset! trailers-atom trailers)))
-      (reify Supplier
-        (get [_] (map->http-fields @trailers-atom))))))
+    (reify Supplier
+      (get [_]
+        (let [trailers (or (async/<!! trailers-ch) {})]
+          (map->http-fields trailers))))))