|
|
@ -226,7 +226,8 @@ namespace Grpc.Core.Internal |
|
|
|
Preconditions.CheckState(readCompletionDelegate == null, "Only one read can be pending at a time"); |
|
|
|
Preconditions.CheckState(readCompletionDelegate == null, "Only one read can be pending at a time"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
protected void CheckNotCancelled() { |
|
|
|
protected void CheckNotCancelled() |
|
|
|
|
|
|
|
{ |
|
|
|
if (cancelRequested) |
|
|
|
if (cancelRequested) |
|
|
|
{ |
|
|
|
{ |
|
|
|
throw new OperationCanceledException("Remote call has been cancelled."); |
|
|
|
throw new OperationCanceledException("Remote call has been cancelled."); |
|
|
@ -301,8 +302,6 @@ namespace Grpc.Core.Internal |
|
|
|
}); |
|
|
|
}); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary> |
|
|
|
/// <summary> |
|
|
|
/// Handles send completion. |
|
|
|
/// Handles send completion. |
|
|
|
/// </summary> |
|
|
|
/// </summary> |
|
|
|