Add Response::eventStream

Author: taylorotwell

src/Illuminate/Routing/ResponseFactory.php

@@ -2,11 +2,13 @@
 
 namespace Illuminate\Routing;
 
+use Closure;
 use Illuminate\Contracts\Routing\ResponseFactory as FactoryContract;
 use Illuminate\Contracts\View\Factory as ViewFactory;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\Response;
 use Illuminate\Routing\Exceptions\StreamedResponseException;
+use Illuminate\Support\Js;
 use Illuminate\Support\Str;
 use Illuminate\Support\Traits\Macroable;
 use Symfony\Component\HttpFoundation\BinaryFileResponse;
@@ -117,6 +119,47 @@ public function jsonp($callback, $data = [], $status = 200, array $headers = [],
         return $this->json($data, $status, $headers, $options)->setCallback($callback);
     }
 
+    /**
+     * Create a new event stream response.
+     *
+     * @param  \Closure  $callback
+     * @param  array  $headers
+     * @param  string  $endStreamWith
+     * @return \Symfony\Component\HttpFoundation\StreamedResponse
+     */
+    public function eventStream(Closure $callback, array $headers = [], string $endStreamWith = '</stream>')
+    {
+        return $this->stream(function () use ($callback, $endStreamWith) {
+            foreach ($callback() as $message) {
+                if (connection_aborted()) {
+                    break;
+                }
+
+                if (! is_string($message) && ! is_numeric($message)) {
+                    $message = Js::encode($message);
+                }
+
+                echo "event: update\n";
+                echo 'data: '.$message;
+                echo "\n\n";
+
+                ob_flush();
+                flush();
+            }
+
+            echo "event: update\n";
+            echo 'data: '.$endStreamWith;
+            echo "\n\n";
+
+            ob_flush();
+            flush();
+        }, 200, array_merge($headers, [
+            'Content-Type' => 'text/event-stream',
+            'Cache-Control' => 'no-cache',
+            'X-Accel-Buffering' => 'no',
+        ]));
+    }
+
     /**
      * Create a new streamed response instance.
      *