From 577b0fb301c488bbe5e51fd624eacc63e79b11cd Mon Sep 17 00:00:00 2001
From: Martyn Smith <martyn@dollyfish.net.nz>
Date: Sun, 8 Jan 2012 15:32:37 +1300
Subject: [PATCH 1/2] Add an emit() method to the Pool

---
 lib/PocketIO/Pool.pm | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/lib/PocketIO/Pool.pm b/lib/PocketIO/Pool.pm
index 65b14e2..43a72f2 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::Socket;
 
 use constant DEBUG => $ENV{POCKETIO_POOL_DEBUG};
 
@@ -67,6 +68,17 @@ sub send {
     return $self;
 }
 
+sub emit {
+    my $self  = shift;
+    my $event = shift;
+
+    $event = PocketIO::Socket->_build_event_message($event, @_);
+
+    $self->send($event);
+
+    return $self;
+}
+
 sub broadcast {
     my $self    = shift;
     my $invoker = shift;

From b0744d3cd247ccb4e3c00481fb3d9740acf0ac7e Mon Sep 17 00:00:00 2001
From: Martyn Smith <martyn@dollyfish.net.nz>
Date: Sun, 8 Jan 2012 22:05:07 +1300
Subject: [PATCH 2/2] Use PocketIO::Message directly

---
 lib/PocketIO/Pool.pm | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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