use AnyEvent::Twitter::Stream;
use Encode;
use Coro;
use Coro::Channel;
use Coro::AnyEvent;
use Coro::Timer;
use IO::Handle::Util qw(io_from_getline);
 
my $app = sub {
    my $env = shift;
 
    my $keyword = $env->{PATH_INFO};
    $keyword =~ s!^/!!;
 
    my $queue = Coro::Channel->new;
 
    # track keywords
    my $guard = AnyEvent::Twitter::Stream->new(
        username => $ENV{TWITTER_USERNAME},
        password => $ENV{TWITTER_PASSWORD},
        method   => "filter",
        track    => $keyword || "twitter",
        on_tweet => sub { $queue->put(@_) },
    );
 
    my $count;
    my $body = io_from_getline sub {
        my $tweet = $queue->get;
        return Encode::encode_utf8($tweet->{text}) . "\n";
    };
 
    return [ 200, ['X-Foo' => 'bar'], $body ];
};