class Mihatter::StreamingWatcher

Attributes

config[R]

Public Class Methods

new(config = {}) click to toggle source
# File lib/mihatter/streaming_watcher.rb, line 5
def initialize(config = {})
  @config = Mihatter.configuration.dup.merge(config)
end

Public Instance Methods

run!() { |obj| ... } click to toggle source
# File lib/mihatter/streaming_watcher.rb, line 11
def run!
  raise ArgumentError, '`Mihatter::StreamingWatcher#run!` require block' unless block_given?
  connect
  @client.filter(track: @config.keyword) do |obj|
    yield obj if obj.is_a?(Twitter::Tweet)
  end
end

Private Instance Methods

connect() click to toggle source
# File lib/mihatter/streaming_watcher.rb, line 21
def connect
  @client = Twitter::Streaming::Client.new do |config|
    config.consumer_key = @config.consumer_key
    config.consumer_secret = @config.consumer_secret
    config.access_token = @config.access_token
    config.access_token_secret = @config.access_token_secret
  end
end