Add skeleton for end() method

Author: clue

Datagram/Buffer.php

@@ -74,4 +74,9 @@ public function close()
         $this->outgoing = array();
         $this->removeAllListeners();
     }
+
+    public function end()
+    {
+
+    }
 }

Datagram/Socket.php

@@ -11,6 +11,7 @@ class Socket extends EventEmitter implements SocketInterface
     protected $socket;
 
     protected $buffer;
+    protected $writable = true;
 
     public $bufferSize = 65536;
 
@@ -93,12 +94,30 @@ public function close()
         $this->pause();
 
         fclose($this->socket);
+        $this->writable = false;
         $this->socket = false;
         $this->buffer->close();
 
         $this->removeAllListeners();
     }
 
+    public function end()
+    {
+        if (!$this->writable) {
+            return;
+        }
+
+        $this->writable = false;
+
+        $that = $this;
+
+        $this->buffer->on('close', function () use ($that) {
+            $that->close();
+        });
+
+        $this->buffer->end();
+    }
+
     private function sanitizeAddress($address)
     {
         // doc comment suggests IPv6 address is not enclosed in square brackets?

Datagram/SocketInterface.php

@@ -10,13 +10,16 @@
  * @event message($data, $remoteAddress, $thisSocket)
  * @event error($exception, $thisSocket)
  * @event close($thisSocket)
+ * @event end($thisSocket);
  */
 interface SocketInterface extends EventEmitterInterface
 {
     public function send($data, $remoteAddress = null);
 
     public function close();
 
+    public function end();
+
     public function resume();
 
     public function pause();