Handle dropped connection in postgres subscriptions. (#226)

Eventuous · Jul 31, 2023 · 780c751 · 780c751
1 parent 22c7ccd
commit 780c751
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/Postgres/src/Eventuous.Postgresql/Subscriptions/PostgresSubscriptionBase.cs b/src/Postgres/src/Eventuous.Postgresql/Subscriptions/PostgresSubscriptionBase.cs
@@ -83,9 +83,8 @@ async Task PollingQuery(ulong? position, CancellationToken cancellationToken) {
                 retryDelay *= 2;
             }
             catch (Exception e) {
-                IsDropped = true;
-                Log.WarnLog?.Log(e, "Dropped");
-                throw;
+                Dropped(DropReason.ServerError, e);
+                break;
             }
         }
     }