Sha256: 5559238c906f501e0c543c95dc68379177aea8b81b622b6f72fb516305b46894
Contents?: true
Size: 439 Bytes
Versions: 22
Compression:
Stored size: 439 Bytes
Contents
# encoding: utf-8
require "logstash/namespace"
require "logstash/logging"
require "logstash/json"
module LogStash; class Logging; class JSON
def initialize(io)
raise ArgumentError, "Expected IO, got #{io.class.name}" unless io.is_a?(IO)
@io = io
@lock = Mutex.new
end
def <<(obj)
serialized = LogStash::Json.dump(obj)
@lock.synchronize do
@io.puts(serialized)
@io.flush
end
end
end; end; end
Version data entries
22 entries across 22 versions & 3 rubygems