Add Buffer skeleton

Author: clue

Datagram/Buffer.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace Datagram;
+
+use React\EventLoop\LoopInterface;
+
+class Buffer
+{
+    private $loop;
+    private $socket;
+    private $listening = false;
+    private $outgoing = array();
+
+    public function __construct(LoopInterface $loop, $socket)
+    {
+        $this->loop = $loop;
+        $this->socket = $socket;
+    }
+
+    public function send($data, $remoteAddress = null)
+    {
+        $this->outgoing []= array($data, $remoteAddress);
+
+        if (!$this->listening) {
+            $this->loop->addWriteStream($this->socket, array($this, 'handleWrite'));
+            $this->listening = true;
+        }
+    }
+
+    public function handleWrite()
+    {
+        list($data, $remoteAddress) = array_shift($this->outgoing);
+
+        if ($remoteAddress === null) {
+            fwrite($this->socket, $data);
+        } else {
+            stream_socket_sendto($this->socket, $data, 0, $remoteAddress);
+        }
+
+        if (!$this->outgoing) {
+            $this->loop->removeWriteStream($this->socket);
+            $this->listening = false;
+        }
+    }
+}

Datagram/Socket.php

@@ -10,13 +10,17 @@ class Socket extends EventEmitter implements SocketInterface
     protected $loop;
     protected $socket;
 
+    protected $buffer;
+
     public $bufferSize = 65536;
 
     public function __construct(LoopInterface $loop, $socket)
     {
         $this->loop = $loop;
         $this->socket = $socket;
 
+        $this->buffer = new Buffer($loop, $socket);
+
         $this->resume();
     }
 
@@ -37,13 +41,9 @@ public function getHost()
         return trim(substr($address, 0, strrpos($address, ':')), '[]');
     }
 
-    public function send($data, $target = null)
+    public function send($data, $remoteAddress = null)
     {
-        if ($target === null) {
-            fwrite($this->socket, $data);
-        } else {
-            stream_socket_sendto($this->socket, $data, 0, $target);
-        }
+        $this->buffer->send($data, $remoteAddress);
     }