We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9751e1d commit 3fe3b93Copy full SHA for 3fe3b93
src/clj/datasplash/pubsub.clj
@@ -25,7 +25,7 @@
25
Payload must be a string and attributes a map."
26
[{:keys [payload attributes]}]
27
(let [attributes-map (->> attributes
28
- (ds/dmap (fn [k v] [(if (keyword? k) (name k) (str k)) (str v)]))
+ (map (fn [[k v]] [(if (keyword? k) (name k) (str k)) (str v)]))
29
(into {}))]
30
(PubsubMessage. (.getBytes payload StandardCharsets/UTF_8) attributes-map)))
31
0 commit comments