Navigation Menu

Skip to content

Commit

Permalink
Remove tag and time from response
Browse files Browse the repository at this point in the history
  • Loading branch information
kou committed Apr 10, 2014
1 parent 40a0201 commit 13c5c8e
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 5 deletions.
6 changes: 3 additions & 3 deletions lib/droonga/client/connection/droonga-protocol/coolio.rb
Expand Up @@ -117,7 +117,7 @@ def handle_engine(engine)
request = @requests[id]
next if request.nil?
request[:received] = true
request[:callback].call(fluent_message)
request[:callback].call(droonga_message)
end
end
engine.on_read do |data|
Expand Down Expand Up @@ -163,9 +163,9 @@ def request(message, options={}, &block)
response = _response
end
end
@receiver.register(id) do
@receiver.register(id) do |response|
@receiver.unregister(id)
block.call
block.call(response)
end
request = Request.new(@receiver, id, @loop)
if sync
Expand Down
5 changes: 3 additions & 2 deletions lib/droonga/client/connection/droonga-protocol/thread.rb
Expand Up @@ -197,8 +197,9 @@ def on_readable(io)
readable, = IO.select([client], nil, nil, 0)
break unless readable
data = client.read_nonblock(BUFFER_SIZE)
unpacker.feed_each(data) do |object|
yield(object)
unpacker.feed_each(data) do |fluent_message|
tag, time, droonga_message = fluent_message
yield(droonga_message)
end
end
client.close
Expand Down

0 comments on commit 13c5c8e

Please sign in to comment.