diff --git a/src/pocketbook/server.clj b/src/pocketbook/server.clj index ebd8a2e..5478266 100644 --- a/src/pocketbook/server.clj +++ b/src/pocketbook/server.clj @@ -66,15 +66,12 @@ (swap! sse-clients update group disj ch)))) (defn- sse-notify! - "Send an SSE event to all listeners of the given groups." + "Send an SSE event to all listeners of the given groups. + After the initial response, http-kit send! takes a plain string body." [groups] (doseq [group groups ch (get @sse-clients group)] - (http/send! ch {:status 200 - :headers {"Content-Type" "text/event-stream" - "Cache-Control" "no-cache"} - :body (str "data: " group "\n\n")} - false))) ;; false = don't close, keep streaming + (http/send! ch (str "data: " group "\n\n") false))) ;; --------------------------------------------------------------------------- ;; Handlers