remove timeout

Author: FGasper

internal/verifier/change_stream.go

@@ -165,18 +165,26 @@ func (verifier *Verifier) iterateChangeStream(ctx context.Context, cs *mongo.Cha
 		}
 
 		if err != nil && !errors.Is(err, context.Canceled) {
-			timeout := time.Minute
-			timer := time.NewTimer(timeout)
-			defer timer.Stop()
+			/*
+				timeout := time.Minute
+				timer := time.NewTimer(timeout)
+				defer timer.Stop()
+
+				select {
+				case <-timer.C:
+					verifier.logger.Fatal().
+						Err(err).
+						Stringer("timeout", timeout).
+						Msg("Failed to send change stream err within timeout.")
+				case verifier.changeStreamErrChan <- err:
+				}
+			*/
 
-			select {
-			case <-timer.C:
-				verifier.logger.Fatal().
-					Err(err).
-					Stringer("timeout", timeout).
-					Msg("Failed to send change stream err within timeout.")
-			case verifier.changeStreamErrChan <- err:
-			}
+			verifier.logger.Warn().
+				Err(err).
+				Msg("Sending change stream error.")
+
+			verifier.changeStreamErrChan <- err
 
 			if !changeStreamEnded {
 				return