Flush out DeferrableBody queue before closing (DeferrableBody#succeed)

macournoyer · Dec 16, 2008 · 0a4a4e9 · 0a4a4e9
1 parent e56cdf6
commit 0a4a4e9
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/example/async_tailer.ru b/example/async_tailer.ru
@@ -17,6 +17,12 @@ class DeferrableBody
 
   def initialize
     @queue = []
+    # make sure to flush out the queue before closing the connection
+    callback{
+      until @queue.empty?
+        @queue.shift.each{|chunk| @body_callback.call(chunk) }
+      end
+    }
   end
 
   def schedule_dequeue