(require '[oxbow.core :as o])

(let [{:keys [abort]} (o/sse-client {:uri "/events"
                                     :on-event #(js/console.log "Got an event!" %)})]

  ;; events are passed to the callback
  ;; call abort to close the client

  (abort))

(require '[oxbow.re-frame :as o])
(require '[re-frame.core :as rf])

(rf/reg-event-db
  ::on-event
  (fn [db [_ {:keys [data] :as event}]]
    (update db :events conj data)))


(rf/dispatch [::o/sse-client {:id ::my-events
                              :uri "/events"
                              :on-event [::on-event]}])

;; events are passed to the callback
;; call abort to close the client

(rf/dispatch [::o/abort ::my-events])

{:fetch-options     {:headers {"Authorization" "xyz"}}        ;; options passed to js/fetch, see https://developer.mozilla.org/en-US/docs/Web/API/WindowOrWorkerGlobalScope/fetch
 :on-open           #(js/console.log "Stream connected" %)    ;; invoked when the stream opens
 :on-close          #(js/console.log "Stream ended")          ;; invoked when the stream ends
 :on-event          #(js/console.log "Message received: " %)  ;; invoked for every event
 :on-error          #(js/console.warn "Error: " %)            ;; invoked on error
 :data-parser       identity                                  ;; parses the `data` value of the event
 :auto-reconnect?   true                                      ;; whether it should automatically reconnect upon disconnection
 :reconnect-timeout 2000                                      ;; ms to wait before attempting reconnect
 }