Properly testing stream

Author: dantleech

tests/Unit/Extension/Core/CoreTestCase.php

@@ -2,11 +2,11 @@
 
 namespace PhpBench\Pipeline\Tests\Unit\Extension\Core;
 
-use PHPUnit\Framework\TestCase;
 use PhpBench\Pipeline\Core\PipelineBuilder;
 use PhpBench\Pipeline\Extension\Core\CoreExtension;
+use PhpBench\Pipeline\Tests\Unit\PipelineTestCase;
 
-class CoreTestCase extends TestCase
+class CoreTestCase extends PipelineTestCase
 {
     protected function pipeline(): PipelineBuilder
     {

tests/Unit/Extension/Core/Stage/Output/StreamOutputTest.php

@@ -7,12 +7,31 @@
 
 class StreamOutputTest extends CoreTestCase
 {
+    private $path;
+
+    public function setUp()
+    {
+        $this->clearWorkspace();
+        $this->path = $this->workspacePath('test.log');;
+    }
+
     public function testWritesToStream()
     {
         $result = $this->pipeline()
-            ->stage('output/stream', ['stream' => 'php://temp'])
+            ->stage('output/stream', ['stream' => $this->path])
             ->generator(['hello'])->current();
 
-        $this->assertEquals(['hello'], $result);
+        $contents = file_get_contents($this->path);
+        $this->assertEquals('hello', trim($contents));
+    }
+
+    public function testSerializesNonScalarValues()
+    {
+        $result = $this->pipeline()
+            ->stage('output/stream', ['stream' => $this->path])
+            ->generator([ [ 'hello' ] ])->current();
+
+        $contents = file_get_contents($this->path);
+        $this->assertEquals('a:1:{i:0;s:5:"hello";}', trim($contents));
     }
 }

tests/Unit/PipelineTestCase.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace PhpBench\Pipeline\Tests\Unit;
+
+use Symfony\Component\Filesystem\Filesystem;
+use PHPUnit\Framework\TestCase;
+
+class PipelineTestCase extends TestCase
+{
+    public function workspaceDir()
+    {
+        return __DIR__ . '/../Workspace';
+    }
+
+    public function workspacePath(string $path)
+    {
+        return $this->workspaceDir() . '/' . $path;
+    }
+
+    public function clearWorkspace()
+    {
+        if (file_exists($this->workspaceDir())) {
+            $filesystem = new Filesystem();
+            $filesystem->remove($this->workspaceDir());
+        }
+
+        mkdir($this->workspaceDir());
+    }
+}