Complete http stream after a response es emitted.

2026-03-12 05:16:23 +00:00 · 2016-10-24 22:18:43 +02:00
parent ea9a096fa9
commit 658636463e
1 changed files with 5 additions and 4 deletions
--- a/src/uxbox/util/http.cljs
+++ b/src/uxbox/util/http.cljs
@@ -74,10 +74,11 @@
       (letfn [(on-complete [event]
                 (if (or (= (.getLastErrorCode xhr) ErrorCode.HTTP_ERROR)
                         (.isSuccess xhr))
-                   (sink {:status (.getStatus xhr)
-                          :body (.getResponse xhr)
-                          :headers (normalize-headers
-                                    (.getResponseHeaders xhr))})
+                   (sink (rx/end
+                          {:status (.getStatus xhr)
+                           :body (.getResponse xhr)
+                           :headers (normalize-headers
+                                     (.getResponseHeaders xhr))}))
                   (sink (let [type (-> (.getLastErrorCode xhr)
                                        (translate-error-code))
                               message (.getLastError xhr)]