(
id: string,
handle: BackendHandle,
op: () => Promise<T>,
)
| 693 | // the cached handle before the error rethrows. Non-transport |
| 694 | // errors pass through untouched. |
| 695 | async #runWithInvalidation<T>( |
| 696 | id: string, |
| 697 | handle: BackendHandle, |
| 698 | op: () => Promise<T>, |
| 699 | ): Promise<T> { |
| 700 | try { |
| 701 | return await op(); |
| 702 | } catch (error) { |
| 703 | if (isWorkspaceTransportFailure(error)) { |
| 704 | this.#invalidateHandle(id, handle); |
| 705 | } |
| 706 | throw error; |
| 707 | } |
| 708 | } |
| 709 | |
| 710 | // Per-backend mutation FIFO. Public push() / pull() calls and each |
| 711 | // command's pre-exec push and post-stream pull route through this; |
no test coverage detected