Fix Single stream benchmark

prooph · Jul 15, 2020 · 259cf3f · 259cf3f
1 parent 7825504
commit 259cf3f
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/StreamCreator.php b/src/StreamCreator.php
@@ -41,16 +41,24 @@ public function run()
 
             $start = \microtime(true);
 
+            $streamName = new StreamName($this->category . '-' . $this->id);
+
             for ($i = 0; $i < $this->executions; $i++) {
                 $count += $this->numberOfEvents;
-                $streamName = $this->category . '-' . Uuid::uuid4()->toString();
                 $events = createTestEvents(testPayload(), $this->numberOfEvents);
 
                 if ($eventStore instanceof TransactionalEventStore) {
                     $eventStore->beginTransaction();
                 }
 
-                $eventStore->create(new Stream(new StreamName($streamName), \SplFixedArray::fromArray($events)));
+                if (getenv('STREAM_STRATEGY') === 'Aggregate') {
+                    $streamName = $this->category . '-' . Uuid::uuid4()->toString();
+                    $eventStore->create(new Stream(new StreamName($streamName), \SplFixedArray::fromArray($events)));
+                } elseif ($i === 0 && $eventStore->hasStream($streamName) === false) {
+                    $eventStore->create(new Stream($streamName, \SplFixedArray::fromArray($events)));
+                } else {
+                    $eventStore->appendTo($streamName, \SplFixedArray::fromArray($events));
+                }
 
                 if ($eventStore instanceof TransactionalEventStore) {
                     $eventStore->commit();