@@ -48,7 +48,7 @@ internal sealed class AutorecoveringChannel : IChannel, IRecoverable
48
48
private AutorecoveringConnection _connection ;
49
49
private RecoveryAwareChannel _innerChannel ;
50
50
51
- private bool _disposedValue ;
51
+ private bool _disposed ;
52
52
private bool _isDisposing ;
53
53
private readonly object _isDisposingLock = new ( ) ;
54
54
@@ -146,7 +146,7 @@ public IAsyncBasicConsumer? DefaultConsumer
146
146
147
147
public bool IsClosed => ! IsOpen ;
148
148
149
- public bool IsOpen => ! _disposedValue && _innerChannel . IsOpen ;
149
+ public bool IsOpen => ! _disposed && _innerChannel . IsOpen ;
150
150
151
151
public string ? CurrentQueue => InnerChannel . CurrentQueue ;
152
152
@@ -158,7 +158,7 @@ internal async Task<bool> AutomaticallyRecoverAsync(AutorecoveringConnection con
158
158
throw new InvalidOperationException ( "recordedEntitiesSemaphore must be held" ) ;
159
159
}
160
160
161
- if ( _disposedValue )
161
+ if ( _disposed )
162
162
{
163
163
return false ;
164
164
}
@@ -195,7 +195,7 @@ await newChannel.TxSelectAsync(cancellationToken)
195
195
* with the resulting basic.ack never getting sent out.
196
196
*/
197
197
198
- if ( _disposedValue )
198
+ if ( _disposed )
199
199
{
200
200
await newChannel . AbortAsync ( CancellationToken . None )
201
201
. ConfigureAwait ( false ) ;
@@ -257,7 +257,7 @@ public override string ToString()
257
257
258
258
public void Dispose ( )
259
259
{
260
- if ( _disposedValue )
260
+ if ( _disposed )
261
261
{
262
262
return ;
263
263
}
@@ -267,7 +267,7 @@ public void Dispose()
267
267
268
268
public async ValueTask DisposeAsync ( )
269
269
{
270
- if ( _disposedValue )
270
+ if ( _disposed )
271
271
{
272
272
return ;
273
273
}
@@ -293,7 +293,7 @@ await this.AbortAsync()
293
293
}
294
294
finally
295
295
{
296
- _disposedValue = true ;
296
+ _disposed = true ;
297
297
_isDisposing = false ;
298
298
}
299
299
}
@@ -504,7 +504,7 @@ public Task TxSelectAsync(CancellationToken cancellationToken)
504
504
[ MethodImpl ( MethodImplOptions . AggressiveInlining ) ]
505
505
private void ThrowIfDisposed ( )
506
506
{
507
- if ( _disposedValue )
507
+ if ( _disposed )
508
508
{
509
509
ThrowDisposed ( ) ;
510
510
}
0 commit comments