Clojurians Log v2

Ring has a protocol ring.core.protocols.StreamableResponseBody. that can be placed in the body of the response. This gives you access to an OutputStream you can use to write to the responose stream. For example:

(defn handler [_request]
  {:status 200
   :headers {"Content-Type" "text/event-stream"}
   :body
   (reify ring.core.protocols.StreamableResponseBody
     (write-body-to-stream [_ _response out-stream]
       (with-open [w ( out-stream)]
         (.write w "event: message\n")
         (.write w "data: Hello World\n\n"))))})

Thanks, I want to send events after handler function ends.

In which case, you'll want to tell Ring you want async handlers. In Duct, you can do this by adding this to your duct.edn :system:

:duct.server.http/jetty {:async? true}

(defn handler [request respond raise]
  (respond {:status 200, :headers ..., :body ...}))