Method: Kafka::SnappyCodec#decompress

Defined in:
lib/kafka/snappy_codec.rb

#decompress(data) ⇒ Object 



24
25
26
27
 
# File 'lib/kafka/snappy_codec.rb', line 24

def decompress(data)
  buffer = StringIO.new(data)
  Snappy::Reader.new(buffer).read
end