Class: Stream

Inherits:
StringIO
  • Object
show all
Defined in:
lib/fluent/plugin/kinesis_helper/compression.rb

Instance Method Summary collapse

Constructor Details

#initializeStream

Returns a new instance of Stream.



5
6
7
8
# File 'lib/fluent/plugin/kinesis_helper/compression.rb', line 5

def initialize(*)
  super
  set_encoding "BINARY"
end

Instance Method Details

#closeObject



10
11
12
# File 'lib/fluent/plugin/kinesis_helper/compression.rb', line 10

def close
  rewind;
end