Fix concurrency problem when receive ResetFrame and HeadFrame (#13062)
This commit is contained in:
parent
edaaa16121
commit
2697652e74
|
|
@ -229,6 +229,9 @@ public abstract class AbstractServerCall implements ServerCall, ServerStream.Lis
|
|||
@Override
|
||||
public final void onCancelByRemote(TriRpcStatus status) {
|
||||
closed = true;
|
||||
if (listener == null) {
|
||||
return;
|
||||
}
|
||||
cancellationContext.cancel(status.cause);
|
||||
listener.onCancel(status);
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue