588
// cancellation to the in-flight `send`.
589
if (placeholder.signal.aborted) {
591
>
void Promise.resolve(built.warm[Symbol.asyncDispose]()).catch((err: unknown) =>
592
>
this._logService.warn(`[ClaudeSdkPipeline:${this.sessionId}] rebind-aborted: warm dispose failed: ${err}`));
593
>
void Promise.resolve(oldWarm[Symbol.asyncDispose]()).catch((err: unknown) =>
594
>
this._logService.warn(`[ClaudeSdkPipeline:${this.sessionId}] previous WarmQuery dispose failed during aborted rebind: ${err}`));
595
>
this._queue.failAll(new CancellationError());
596
>
this._needsRebind = true;
597
>
throw new CancellationError();
598
>
}
599
void Promise.resolve(oldWarm[Symbol.asyncDispose]()).catch((err: unknown) =>
600
this._logService.warn(`[ClaudeSdkPipeline:${this.sessionId}] previous WarmQuery dispose failed during rebind: ${err}`));