partial revert

FGasper · FGasper · commit 9dd0100684d3 · 2024-11-22T02:21:50.000-05:00
diff --git a/internal/verifier/change_stream.go b/internal/verifier/change_stream.go
@@ -271,7 +271,7 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
 			verifier.mux.Unlock()
 			// since we have started Recheck, we must signal that we have
 			// finished the change stream changes so that Recheck can continue.
-			close(verifier.changeStreamDoneChan)
+			verifier.changeStreamDoneChan <- struct{}{}
 			break
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -271,7 +271,7 @@ func (verifier Verifier) iterateChangeStream(ctx context.Context, cs mongo.Cha`
`271`	`271`	`verifier.mux.Unlock()`
`272`	`272`	`// since we have started Recheck, we must signal that we have`
`273`	`273`	`// finished the change stream changes so that Recheck can continue.`
`274`		`- close(verifier.changeStreamDoneChan)`
	`274`	`+ verifier.changeStreamDoneChan <- struct{}{}`
`275`	`275`	`break`
`276`	`276`	`}`
`277`	`277`	`}`