Sha256: d28ee32e186c15d09f5998f9d8e616adebdbc6d6be014089673292410beee45f
Contents?: true
Size: 924 Bytes
Versions: 8
Compression:
Stored size: 924 Bytes
Contents
require 'logstash/devutils/rspec/spec_helper'
require 'logstash/inputs/twitter'
require 'twitter'
require 'rspec_sequencing'
creds_file_path = File.expand_path('spec/integration_credentials.rb')
if File.exist?(creds_file_path)
load creds_file_path
RSpec.configure do |config|
# enable integrations only when credentials are loaded
exclusions = config.exclusion_filter
exclusions.delete(:integration)
config.exclusion_filter = exclusions
end
end
module LogstashTwitterInput
class MockClient
def filter(options)
loop { yield }
end
alias_method :sample, :filter
end
def self.run_input_with(input, queue)
t = Thread.new(input, queue) do |_input, _queue|
_input.run(_queue)
end
sleep 0.1
t.kill
end
def self.fixture_path
File.expand_path('../fixtures', __FILE__)
end
def self.fixture(file)
File.new(self.fixture_path + '/' + file)
end
end
Version data entries
8 entries across 8 versions & 1 rubygems