0
@@ -1,4 +1,5 @@
0
 require 'sync/diff'
0
+require 'sync/queues'
0
 require 'sync/chain_sync'
0
 require 'sync/store_sync'
0
 require 'sync/lamport_timestamp'
0
\ No newline at end of file

0
@@ -13,7 +13,21 @@ module StrokeDB
0
     # on_receive callback is called when the queue decides do pop
0
     # out an object. If there is no on_receive, it waits for the #pop call.
0
     def on_recieve(&block)
0
-      @on_receive = block || @on_receive
0
+      self.on_receive = block if block
0
+      @on_receive
0
+    end
0
+    
0
+    def on_receive=(proc)
0
+      @on_receive = proc
0
+      # define notify! method to invoke a callback
0
+      class << self
0
+        def notify!
0
+          while item = pop
0
+            @on_receive.call(item)
0
+          end
0
+        end
0
+      end
0
+      proc
0
     end
0
     
0
     # Get an object out of the queue. 
0
@@ -26,5 +40,12 @@ module StrokeDB
0
       raise "Abstract queue doesn't have a size"
0
     end
0
     alias :length :size
0
+  
0
+  protected
0
+  
0
+    def notify!
0
+      # do nothing while on_receive is not set
0
+    end
0
+  
0
   end
0
 end