(feat) added channel close handler to fail request fast

Signed-off-by: Ning Sun <sunng@about.me>
sunng87 · Apr 23, 2016 · 795115d · 795115d
1 parent b817bc2
commit 795115d
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/slacker/client/common.clj b/src/slacker/client/common.clj
@@ -314,7 +314,17 @@
                   (instance? ConnectException exc)
                   (instance? ClosedChannelException exc))
                (log/warn "Failed to connect to server or connection lost.")
-               (log/error exc "Unexpected error in event loop")))))
+               (log/error exc "Unexpected error in event loop")))
+   (on-inactive [ch]
+                (let [rmap (-> ch
+                               (channel-hostport)
+                               (@server-requests)
+                               :pendings)]
+                  (doseq [handler (vals @rmap)]
+                    (when (not-empty handler)
+                      (deliver (:promise handler)
+                               {:cause {:error :connection-broken}})))
+                  (reset! rmap {})))))
 
 (def ^:dynamic *options*
   {:tcp-nodelay true