1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
require 'rubygems'
lib_path = File.expand_path(File.join(File.dirname(__FILE__), '..', 'lib'))
$LOAD_PATH.unshift lib_path unless $LOAD_PATH.include?(lib_path)
require 'twitter/json_stream'
EventMachine::run {
stream = Twitter::JSONStream.connect(
:path => '/1/statuses/filter.json',
:auth => 'LOGIN:PASSWORD',
:method => 'POST',
:content => 'track=basketball,football,baseball,footy,soccer'
)
stream.each_item do |item|
$stdout.print "item: #{item}\n"
$stdout.flush
end
stream.on_error do |message|
$stdout.print "error: #{message}\n"
$stdout.flush
end
stream.on_reconnect do |timeout, retries|
$stdout.print "reconnecting in: #{timeout} seconds\n"
$stdout.flush
end
stream.on_max_reconnects do |timeout, retries|
$stdout.print "Failed after #{retries} failed reconnects\n"
$stdout.flush
end
trap('TERM') {
stream.stop
EventMachine.stop if EventMachine.reactor_running?
}
}
puts "The event loop has ended"
|
