add nil check for aggregator during WaitStop

Signed-off-by: Alex Shorsher <alex.shorsher@kaleido.io>
hyperledger · Aug 18, 2022 · 409594e · 409594e
1 parent d4f5c87
commit 409594e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/events/event_manager.go b/internal/events/event_manager.go
@@ -202,7 +202,9 @@ func (em *eventManager) WaitStop() {
 		em.blobReceiver.stop()
 		em.blobReceiver = nil
 	}
-	<-em.aggregator.eventPoller.closed
+	if em.aggregator != nil {
+		<-em.aggregator.eventPoller.closed
+	}
 }
 
 func (em *eventManager) CreateUpdateDurableSubscription(ctx context.Context, subDef *core.Subscription, mustNew bool) (err error) {