class LogStash::Inputs::Stdin::InputHandler

Public Class Methods

new(obj) click to toggle source
# File lib/logstash/inputs/stdin.rb, line 26
def initialize(obj)
  @receiver = obj
end

Public Instance Methods

receive_data(data) click to toggle source
# File lib/logstash/inputs/stdin.rb, line 30
def receive_data(data)
  @buffer ||= BufferedTokenizer.new
  @buffer.extract(data).each do |line|
    @receiver.receive(line)
  end
end