File tree Expand file tree Collapse file tree 1 file changed +1
-9
lines changed
src/MongoDB.Driver.Core/Core/Operations Expand file tree Collapse file tree 1 file changed +1
-9
lines changed Original file line number Diff line number Diff line change @@ -23,7 +23,6 @@ internal static class RetryabilityHelper
23
23
// private static fields
24
24
private static readonly HashSet < ServerErrorCode > __notResumableChangeStreamErrorCodes ;
25
25
private static readonly HashSet < Type > __resumableChangeStreamExceptions ;
26
- private static readonly HashSet < ServerErrorCode > __resumableChangeStreamErrorCodes ;
27
26
private static readonly HashSet < Type > __retryableWriteExceptions ;
28
27
private static readonly HashSet < ServerErrorCode > __retryableWriteErrorCodes ;
29
28
@@ -54,13 +53,6 @@ static RetryabilityHelper()
54
53
ServerErrorCode . SocketException
55
54
} ;
56
55
57
- __resumableChangeStreamErrorCodes = new HashSet < ServerErrorCode > ( resumableAndRetryableErrorCodes )
58
- {
59
- ServerErrorCode . ElectionInProgress ,
60
- ServerErrorCode . ExceededTimeLimit ,
61
- ServerErrorCode . RetryChangeStream ,
62
- } ;
63
-
64
56
__retryableWriteErrorCodes = new HashSet < ServerErrorCode > ( resumableAndRetryableErrorCodes )
65
57
{
66
58
ServerErrorCode . WriteConcernFailed
@@ -81,7 +73,7 @@ public static bool IsResumableChangeStreamException(Exception exception)
81
73
if ( commandException != null )
82
74
{
83
75
var code = ( ServerErrorCode ) commandException . Code ;
84
- return __resumableChangeStreamErrorCodes . Contains ( code ) || ! __notResumableChangeStreamErrorCodes . Contains ( code ) ;
76
+ return ! __notResumableChangeStreamErrorCodes . Contains ( code ) ;
85
77
}
86
78
else
87
79
{
You can’t perform that action at this time.
0 commit comments