From a91f4b6af823ec679d3d64fc9262a70f189da472 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E2=98=99=E2=97=A6=20The=20Tablet=20=E2=9D=80=20GamerGirla?= =?UTF-8?q?ndCo=20=E2=97=A6=E2=9D=A7?= Date: Wed, 26 Mar 2025 20:34:49 -0400 Subject: [PATCH] fall back to not panicking if replication isn't enabled... --- registry.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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)