Object
# File lib/fluent/buffer.rb, line 69 def initialize(key) super() @key = key end
def size end
# File lib/fluent/buffer.rb, line 82 def empty? size == 0 end
# File lib/fluent/buffer.rb, line 104 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 98 def write_to(io) open {|i| FileUtils.copy_stream(i, io) } end
[Validate]
Generated with the Darkfish Rdoc Generator 2.