Sha256: 5ce873f2eeb4a0cba4ecdff3b7b2952b491bea33fa66550948afdcb144205c79
Contents?: true
Size: 440 Bytes
Versions: 123
Compression:
Stored size: 440 Bytes
Contents
# encoding: utf-8
require "logstash/namespace"
require "logstash/logging"
require "logstash/json"
module LogStash; module 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
123 entries across 120 versions & 14 rubygems