diff --git a/registry.go b/registry.go
index d4e5023..8342f13 100644
--- a/registry.go
+++ b/registry.go
@@ -337,7 +337,9 @@ func innerWatch(coll *mongo.Collection) {
 	}
 
 	stream, err := coll.Watch(context.TODO(), sspipeline, options.ChangeStream().SetFullDocument(options.UpdateLookup).SetFullDocumentBeforeChange(options.WhenAvailable))
-	panik(err)
+	if err != nil {
+		return
+	}
 	defer func(stream *mongo.ChangeStream, ctx context2.Context) {
 		err := stream.Close(ctx)
 		panik(err)