Object
# File lib/fluent/buffer.rb, line 71 def initialize(key) super() @key = key end
def size end
# File lib/fluent/buffer.rb, line 84 def empty? size == 0 end
# File lib/fluent/buffer.rb, line 106 def msgpack_each(&block) open {|io| u = MessagePack::Unpacker.new(io) begin u.each(&block) rescue EOFError end } end
def open end
# File lib/fluent/buffer.rb, line 100 def write_to(io) open {|i| FileUtils.copy_stream(i, io) } end
[Validate]
Generated with the Darkfish Rdoc Generator 2.