Merge 665e8ec into 2a2eb09

prooph · Apr 26, 2020 · 3d14739 · 3d14739
2 parents 2a2eb09 + 665e8ec
commit 3d14739
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/Internal/EventStoreConnectionLogicHandler.php b/src/Internal/EventStoreConnectionLogicHandler.php
@@ -657,7 +657,10 @@ private function startSubscription(StartSubscriptionMessage $message): void
                     $message->userCredentials(),
                     fn (EventStoreSubscription $subscription, ResolvedEvent $resolvedEvent): Promise => ($message->eventAppeared())($subscription, $resolvedEvent),
                     function (EventStoreSubscription $subscription, SubscriptionDropReason $reason, ?Throwable $exception = null) use ($message): void {
-                        ($message->subscriptionDropped())($subscription, $reason, $exception);
+                        $subscriptionDroppedHandler = $message->subscriptionDropped();
+                        if ($subscriptionDroppedHandler !== null) {
+                            $subscriptionDroppedHandler($subscription, $reason, $exception);
+                        }
                     },
                     $this->settings->verboseLogging(),
                     fn (): ?TcpPackageConnection => $this->connection