AnyEvent::Gnip::Stream - Receive Gnip Power Track streaming API in an event loop
use AnyEvent::Gnip::Stream;
# receive updates from Gnip Power Track
my $done = AE::cv;
my $listener = AnyEvent::Gnip::Stream->new(
user => $user,
password => $password,
stream_url => $stream_url,
on_tweet => sub {
my $tweet = shift;
print $tweet->{actor}->{preferredUsername}.": ".$tweet->{body}."\n";
},
on_error => sub {
warn shift."\n";
$done->send;
},
on_connect => sub {
print "Stream started!\n";
},
on_eof => sub {
warn "EOF\n";
$done->send;
},
on_keepalive => sub {
warn "ping\n";
},
timeout => 60,
);
$done->recv;AnyEvent::Gnip::Stream is an AnyEvent user to receive Gnip Power Track streaming API, available at http://docs.gnip.com/w/page/35663947/Power-Track and http://docs.gnip.com/w/page/37218164/Getting%20Started%20with%20Commercial%20Twitter%20Data.
See "track.pl" in eg for more client code example.
- user password
-
These arguments are used for basic authentication.
- stream_url
-
URL of the Gnip collector to link to.
- timeout
-
Set the timeout value.
- on_connect
-
Callback to execute when a stream is connected.
- on_tweet
-
Callback to execute when a new tweet is received.
- on_error
-
Callback to execute when an error occurs.
- on_eof
- on_keepalive
- no_decode_json
-
Set this param to TRUE if you don't want to deserialize json input from the stream.
The API uses the HTTPS protocol. For this, you need to install the Net::SSLeay module.
Stéphane Raux <stephane.raux@linkfluence.net>
(Based on Tatsuhiko Miyagawa's AnyEvent::Twitter::Stream)
This library is free software; you can redistribute it and/or modify it under the same terms as Perl itself.