NAME

Net::Async::Pusher - support for pusher.com streaming event API

VERSION

version 0.001

SYNOPSIS

 #!/usr/bin/env perl
 use strict;
 use warnings;
 use feature qw(say);
 
 # For more details, enable this
 # use Log::Any::Adapter qw(Stdout);
 
 use IO::Async::Loop;
 use Net::Async::Pusher;
 
 my $loop = IO::Async::Loop->new;
 
 $loop->add(
        my $pusher = Net::Async::Pusher->new
 );
 say "Connecting to pusher.com via websocket...";
 my $sub = $pusher->connect(
        key => 'de504dc5763aeef9ff52'
 )->then(sub {
        my ($conn) = @_;
        say "Connection established. Opening channel.";
        $conn->open_channel('live_trades')
 })->then(sub {
        my ($ch) = @_;
        say "Have channel, setting up event handler for 'trade' event.";
        $ch->subscribe(trade => sub {
                my ($ev, $data) = @_;
                say "New trade - price " . $data->{price} . ", amount " . $data->{amount};
        });
 })->get;
 say "Subscribed and waiting for events...";
 $loop->run;
 $sub->()->get;

DESCRIPTION

Provides basic integration with the https://pusher.com|Pusher API.

connect

Connects to a server using a key.

 my $conn = $pusher->connect(
  key => 'abc123'
 )->get;

Resolves to a Net::Async::Pusher::Connection.

INHERITED METHODS

IO::Async::Notifier

add_child, adopt_future, can_event, children, configure, configure_unknown, debug_printf, get_loop, invoke_error, invoke_event, loop, make_event_cb, maybe_invoke_event, maybe_make_event_cb, new, notifier_name, parent, remove_child, remove_from_parent

AUTHOR

Tom Molesworth <cpan@perlsite.co.uk>

LICENSE

Copyright Tom Molesworth 2015. Licensed under the same terms as Perl itself.