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