Sha256: 0c0a26c3def18fa3e9f704e822955f15afc4eef6de625482cb467b7add4138c5
Contents?: true
Size: 462 Bytes
Versions: 31
Compression:
Stored size: 462 Bytes
Contents
# frozen_string_literal: true
module Kafka
class SnappyCodec
def codec_id
2
end
def load
require "snappy"
rescue LoadError
raise LoadError,
"Using snappy compression requires adding a dependency on the `snappy` gem to your Gemfile."
end
def compress(data)
Snappy.deflate(data)
end
def decompress(data)
buffer = StringIO.new(data)
Snappy::Reader.new(buffer).read
end
end
end
Version data entries
31 entries across 31 versions & 2 rubygems