Contents

require "logstash/devutils/rspec/spec_helper"
require 'logstash/inputs/twitter'
require 'twitter'

class MockClient
  def filter(options)
    loop { yield }
  end
  alias_method :sample, :filter
end

def run_input_with(input, queue)
  t = Thread.new(input, queue) do |_input, _queue|
    _input.run(_queue)
  end
  sleep 0.1
  t.kill
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
logstash-input-twitter-3.0.2	spec/spec_helper.rb
logstash-input-twitter-3.0.1	spec/spec_helper.rb
logstash-input-twitter-3.0.0	spec/spec_helper.rb
logstash-input-twitter-2.2.2	spec/spec_helper.rb
logstash-input-twitter-2.2.0	spec/spec_helper.rb