try to resolve bugs

prooph · Oct 20, 2018 · a59554f · a59554f
1 parent 806d91c
commit a59554f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/tests/connect_to_existing_persistent_subscription_with_start_from_x_set_and_events_in_it.php b/tests/connect_to_existing_persistent_subscription_with_start_from_x_set_and_events_in_it.php
@@ -73,6 +73,7 @@ protected function given(): Generator
             new class($this->resetEvent, $this->firstEvent) implements EventAppearedOnPersistentSubscription {
                 private $deferred;
                 private $firstEvent;
+                private $set = false;
 
                 public function __construct($deferred, &$firstEvent)
                 {
@@ -85,8 +86,11 @@ public function __invoke(
                     ResolvedEvent $resolvedEvent,
                     ?int $retryCount = null
                 ): Promise {
-                    $this->firstEvent = $resolvedEvent;
-                    $this->deferred->resolve(true);
+                    if (! $this->set) {
+                        $this->set = true;
+                        $this->firstEvent = $resolvedEvent;
+                        $this->deferred->resolve(true);
+                    }
 
                     return new Success();
                 }

diff --git a/tests/soft_delete.php b/tests/soft_delete.php
@@ -276,7 +276,7 @@ public function soft_deleted_stream_allows_recreation_when_expver_is_exact(): vo
                 100,
                 false
             );
-
+            \var_dump($result);
             $this->assertTrue(SliceReadStatus::success()->equals($result->status()));
             $this->assertSame(4, $result->lastEventNumber());
             $this->assertCount(3, $result->events());