diff --git a/lib/PocketIO/Pool.pm b/lib/PocketIO/Pool.pm index 65b14e2..2b6f8f2 100644 --- a/lib/PocketIO/Pool.pm +++ b/lib/PocketIO/Pool.pm @@ -6,6 +6,7 @@ use warnings; use Scalar::Util qw(blessed); use PocketIO::Connection; +use PocketIO::Message; use constant DEBUG => $ENV{POCKETIO_POOL_DEBUG}; @@ -67,6 +68,20 @@ sub send { return $self; } +sub emit { + my $self = shift; + my $event = shift; + + $event = PocketIO::Message->new( + type => 'event', + data => {name => $event, args => [@_]} + ); + + $self->send($event); + + return $self; +} + sub broadcast { my $self = shift; my $invoker = shift;