WyriHaximus / reactphp-stream-base64

src/WritableStreamBase64Decode.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
     {
         $this->buffer .= $data;
         $this->stream->end(
-            $this->processBuffer() . base64_decode($this->buffer, true)
+            $this->processBuffer().base64_decode($this->buffer, true)
         );
         $this->buffer = '';
     }

src/ReadableStreamBase64Encode.php

Spacing +2 added lines, -2 removed lines

@@ -25,11 +25,11 @@
     public function __construct(ReadableStreamInterface $stream)
     {
         $this->stream = $stream;
-        $this->stream->on('data', function ($data) {
+        $this->stream->on('data', function($data) {
             $this->buffer .= $data;
             $this->emit('data', [$this->processBuffer()]);
         });
-        $this->stream->once('close', function () {
+        $this->stream->once('close', function() {
             $this->emit('data', [base64_encode($this->buffer)]);
             $this->emit('close');
         });

src/WritableStreamBase64Encode.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
     {
         $this->buffer .= $data;
         $this->stream->end(
-            $this->processBuffer() . base64_encode($this->buffer)
+            $this->processBuffer().base64_encode($this->buffer)
         );
         $this->buffer = '';
     }

src/ReadableStreamBase64Decode.php

Spacing +2 added lines, -2 removed lines

@@ -25,11 +25,11 @@
     public function __construct(ReadableStreamInterface $stream)
     {
         $this->stream = $stream;
-        $this->stream->on('data', function ($data) {
+        $this->stream->on('data', function($data) {
             $this->buffer .= $data;
             $this->emit('data', [$this->processBuffer()]);
         });
-        $this->stream->once('close', function () {
+        $this->stream->once('close', function() {
             $this->emit('data', [base64_decode($this->buffer, true)]);
             $this->emit('close');
         });