view release on metacpan or  search on metacpan

lib/Net/Async/Pusher.pod  view on Meta::CPAN

=encoding utf8

=for comment POD_DERIVED_INDEX_GENERATED
The following documentation is automatically generated.  Please do not edit
this file, but rather the original, inline with Net::Async::Pusher
at lib/Net/Async/Pusher.pm
(on the system that originally ran this).
If you do edit this file, and don't want your changes to be removed, make
sure you change the first line.

=cut

=head1 NAME

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

=head1 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;

=head1 DESCRIPTION

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

=head2 connect

Connects to a server using a key.

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

Resolves to a L<Net::Async::Pusher::Connection>.

=head1 INHERITED METHODS

=over 4

=item L<IO::Async::Notifier>

L<add_child|IO::Async::Notifier/add_child>, L<adopt_future|IO::Async::Notifier/adopt_future>, L<adopted_futures|IO::Async::Notifier/adopted_futures>, L<can_event|IO::Async::Notifier/can_event>, L<children|IO::Async::Notifier/children>, L<configure|IO...

=back

=head1 AUTHOR