spec/node/zmq_pushpull_spec.rb in dripdrop-0.9.10 vs spec/node/zmq_pushpull_spec.rb in dripdrop-0.10.0.beta1

@@ -5,11 +5,11 @@
   def pp_send_messages(to_send)
     responses = []
     push = nil
     pull = nil
     
-    @node = run_reactor do
+    @node = run_reactor(2) do
       addr = rand_addr
       
       push = zmq_push(addr, :bind)
       
       pull1 = zmq_pull(addr, :connect)
@@ -23,9 +23,11 @@
        pull2.on_recv do |message|
         message.head['recv_sock'] = 2
         responses << message
       end
        
+      sleep 1
+
       to_send.each {|message| push.send_message(message)}
     end
      
     {:responses => responses, :handlers => { :push => push, :pull => [pull] }}
   end