tests

prooph · Mar 3, 2017 · b2f0da2 · b2f0da2
1 parent 50c0b48
commit b2f0da2
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/tests/AllStreamProjectionRunnerTest.php b/tests/AllStreamProjectionRunnerTest.php
@@ -15,6 +15,7 @@
 use PHPUnit\Framework\TestCase;
 use Prooph\Common\Event\ProophActionEventEmitter;
 use Prooph\EventStore\InMemoryEventStore;
+use Prooph\EventStore\Projection\InMemoryProjectionManager;
 use Prooph\EventStore\Stream;
 use Prooph\EventStore\StreamName;
 use Prooph\StandardProjections\AllStreamProjectionRunner;
@@ -69,7 +70,8 @@ public function it_emits_events_for_all_streams()
 
         $eventStore->commit();
 
-        $allStreamProjection = new AllStreamProjectionRunner($eventStore);
+        $projectionManager = new InMemoryProjectionManager($eventStore);
+        $allStreamProjection = new AllStreamProjectionRunner($projectionManager);
         $allStreamProjection(false);
 
         $this->assertTrue($eventStore->hasStream(new StreamName('$all')));

diff --git a/tests/CategoryStreamProjectionRunnerTest.php b/tests/CategoryStreamProjectionRunnerTest.php
@@ -15,6 +15,7 @@
 use PHPUnit\Framework\TestCase;
 use Prooph\Common\Event\ProophActionEventEmitter;
 use Prooph\EventStore\InMemoryEventStore;
+use Prooph\EventStore\Projection\InMemoryProjectionManager;
 use Prooph\EventStore\Stream;
 use Prooph\EventStore\StreamName;
 use Prooph\StandardProjections\CategoryStreamProjectionRunner;
@@ -83,7 +84,8 @@ public function it_emits_events_for_all_streams()
 
         $eventStore->commit();
 
-        $categoryStreamProjection = new CategoryStreamProjectionRunner($eventStore);
+        $projectionManager = new InMemoryProjectionManager($eventStore);
+        $categoryStreamProjection = new CategoryStreamProjectionRunner($projectionManager);
         $categoryStreamProjection(false);
 
         $this->assertTrue($eventStore->hasStream(new StreamName('$ct-foo')));

diff --git a/tests/MessageNameStreamProjectionRunnerTest.php b/tests/MessageNameStreamProjectionRunnerTest.php
@@ -15,6 +15,7 @@
 use PHPUnit\Framework\TestCase;
 use Prooph\Common\Event\ProophActionEventEmitter;
 use Prooph\EventStore\InMemoryEventStore;
+use Prooph\EventStore\Projection\InMemoryProjectionManager;
 use Prooph\EventStore\Stream;
 use Prooph\EventStore\StreamName;
 use Prooph\StandardProjections\MessageNameStreamProjectionRunner;
@@ -53,7 +54,8 @@ public function it_emits_events_for_all_streams()
 
         $eventStore->commit();
 
-        $categoryStreamProjection = new MessageNameStreamProjectionRunner($eventStore);
+        $projectionManager = new InMemoryProjectionManager($eventStore);
+        $categoryStreamProjection = new MessageNameStreamProjectionRunner($projectionManager);
         $categoryStreamProjection(false);
 
         $this->assertTrue($eventStore->hasStream(new StreamName('$mn-event-a')));