[Groonga-commit] droonga/droonga-client-ruby at ef9ea8b [master] Revert "Return all messages by Receiver#receive"

Back to archive index

YUKI Hiroshi null+****@clear*****
Tue Oct 29 10:06:18 JST 2013


YUKI Hiroshi	2013-10-29 10:06:18 +0900 (Tue, 29 Oct 2013)

  New Revision: ef9ea8b6768f80fb2748098c680b131474bad530
  https://github.com/droonga/droonga-client-ruby/commit/ef9ea8b6768f80fb2748098c680b131474bad530

  Message:
    Revert "Return all messages by Receiver#receive"
    
    Because it is wrong way.
    This reverts commit efaea3d4a6469853767da48443bb891934bdbd29.

  Modified files:
    lib/droonga/client/connection/droonga_protocol.rb

  Modified: lib/droonga/client/connection/droonga_protocol.rb (+5 -4)
===================================================================
--- lib/droonga/client/connection/droonga_protocol.rb    2013-10-29 10:05:46 +0900 (b97ab52)
+++ lib/droonga/client/connection/droonga_protocol.rb    2013-10-29 10:06:18 +0900 (03c3c11)
@@ -53,7 +53,7 @@ module Droonga
             envelope = envelope.dup
             envelope["replyTo"] = "#{receiver.host}:#{receiver.port}/droonga"
             @logger.post("message", envelope)
-            receiver.receive(:timeout => @timeout).first
+            receiver.receive(:timeout => @timeout)
           ensure
             receiver.close
           end
@@ -84,13 +84,14 @@ module Droonga
           def receive(options={})
             if IO.select([@socket], nil, nil, options[:timeout])
               client =****@socke*****
-              messages = []
+              response = nil
               unpacker = MessagePack::Unpacker.new(client)
               unpacker.each do |object|
-                messages << object
+                response = object
+                break
               end
               client.close
-              messages
+              response
             else
               nil
             end
-------------- next part --------------
HTML����������������������������...
Download 



More information about the Groonga-commit mailing list
Back to archive index