added release-pending-sends

1 files changed, 9 insertions, 0 deletions

diff --git a/src/clj/clojure/core.clj b/src/clj/clojure/core.clj
index 4cb7fd66..c6e81bad 100644
--- a/src/clj/clojure/core.clj
+++ b/src/clj/clojure/core.clj
@@ -1074,6 +1074,15 @@
   [#^clojure.lang.Agent a f & args]
     (. a (dispatch f args true)))
 
+(defn release-pending-sends 
+  "Normally, actions sent directly or indirectly during another action
+  are held until the action completes (changes the agent's
+  state). This function can be used to dispatch any pending sent
+  actions immediately. This has no impact on actions sent during a
+  transaction, which are still held until commit. If no action is
+  occurring, does nothing. Returns the number of actions dispatched."  
+  [] (clojure.lang.Agent/releasePendingSends))
+
 (defn add-watch
   "Experimental.
   Adds a watcher to an agent. Whenever the agent runs an action, any