diff --git a/packages/ditto/storages/DittoPgStore.ts b/packages/ditto/storages/DittoPgStore.ts
index 000ef536..4ec7a6ca 100644
--- a/packages/ditto/storages/DittoPgStore.ts
+++ b/packages/ditto/storages/DittoPgStore.ts
@@ -307,6 +307,8 @@ export class DittoPgStore extends NPostgres {
         yield ['CLOSED', subId, 'error: the relay could not respond fast enough'];
         return;
       }
+    } else {
+      yield ['EOSE', subId];
     }
 
     this.subs.set(subId, { filters, machina });