File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
projects/RabbitMQ.Client/client/impl Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -81,7 +81,7 @@ public void Dispose()
81
81
public void Enqueue ( IRpcContinuation k )
82
82
{
83
83
IRpcContinuation result = Interlocked . CompareExchange ( ref _outstandingRpc , k , s_tmp ) ;
84
- if ( ! ( result is EmptyRpcContinuation ) )
84
+ if ( result is not EmptyRpcContinuation )
85
85
{
86
86
throw new NotSupportedException ( $ "Pipelining of requests forbidden (attempted: { k . GetType ( ) } , enqueued: { result . GetType ( ) } )") ;
87
87
}
@@ -123,7 +123,7 @@ public IRpcContinuation Next()
123
123
/// waiting continuations.
124
124
///</para>
125
125
///</remarks>
126
- public bool TryPeek < T > ( [ MaybeNullWhen ( false ) ] out T continuation ) where T : IRpcContinuation
126
+ public bool TryPeek < T > ( [ NotNullWhen ( true ) ] out T ? continuation ) where T : class , IRpcContinuation
127
127
{
128
128
if ( _outstandingRpc is T result )
129
129
{
You can’t perform that action at this time.
0 commit comments