lib/kafka/connection.rb in ruby-kafka-0.1.0.pre.beta3 vs lib/kafka/connection.rb in ruby-kafka-0.1.0.pre.beta4
- old
+ new
@@ -1,6 +1,7 @@
require "socket"
+require "stringio"
require "kafka/protocol/request_message"
require "kafka/protocol/encoder"
require "kafka/protocol/decoder"
module Kafka
@@ -65,10 +66,10 @@
#
# @param api_key [Integer] the integer code for the API that is invoked.
# @param request [#encode] the request that should be encoded and written.
# @param response_class [#decode] an object that can decode the response.
#
- # @return [Object] the response that was decoded by +response_class+.
+ # @return [Object] the response that was decoded by `response_class`.
def request(api_key, request, response_class)
write_request(api_key, request)
unless response_class.nil?
loop do