diff --git a/packages/core/src/common/message-rpc/rpc-protocol.ts b/packages/core/src/common/message-rpc/rpc-protocol.ts index 6dfdbb125dad9..ce96bdaaab781 100644 --- a/packages/core/src/common/message-rpc/rpc-protocol.ts +++ b/packages/core/src/common/message-rpc/rpc-protocol.ts @@ -132,15 +132,11 @@ export class RpcProtocol { // The last element of the request args might be a cancellation token. As these tokens are not serializable we have to remove it from the // args array and the `CANCELLATION_TOKEN_KEY` string instead. const cancellationToken: CancellationToken | undefined = args.length && CancellationToken.is(args[args.length - 1]) ? args.pop() : undefined; - if (cancellationToken && cancellationToken.isCancellationRequested) { - return Promise.reject(this.cancelError()); - } if (cancellationToken) { args.push(RpcProtocol.CANCELLATION_TOKEN_KEY); cancellationToken.onCancellationRequested(() => { this.sendCancel(id); - this.pendingRequests.get(id)?.reject(this.cancelError()); } ); } @@ -164,12 +160,6 @@ export class RpcProtocol { output.commit(); } - cancelError(): Error { - const error = new Error('"Request has already been canceled by the sender"'); - error.name = 'Cancel'; - return error; - } - protected handleCancel(id: number): void { const cancellationTokenSource = this.cancellationTokenSources.get(id); if (cancellationTokenSource) {