Buffer sends events

Author: clue

Datagram/Buffer.php

@@ -2,10 +2,11 @@
 
 namespace Datagram;
 
+use Evenement\EventEmitter;
 use React\EventLoop\LoopInterface;
 use \Exception;
 
-class Buffer
+class Buffer extends EventEmitter
 {
     private $loop;
     private $socket;
@@ -46,7 +47,7 @@ public function handleWrite()
 
         if ($ret < 0) {
             $error = error_get_last();
-            throw new Exception('Unable to send packet: ' . $error['message']);
+            $this->emit('error', array(new Exception('Unable to send packet: ' . $error['message'])));
         }
 
         if (!$this->outgoing) {
@@ -61,12 +62,15 @@ public function close()
             return false;
         }
 
+        $this->emit('close', array($this));
+
         if ($this->listening) {
             $this->loop->removeWriteStream($this->socket);
             $this->listening = false;
         }
 
         $this->socket = false;
         $this->outgoing = array();
+        $this->removeAllListeners();
     }
 }

Datagram/Socket.php

@@ -20,6 +20,11 @@ public function __construct(LoopInterface $loop, $socket)
         $this->socket = $socket;
 
         $this->buffer = new Buffer($loop, $socket);
+        $that = $this;
+        $this->buffer->on('error', function ($error) use ($that) {
+            $that->emit('error', array($error, $that));
+        });
+        $this->buffer->on('close', array($this, 'close'));
 
         $this->resume();
     }