(reason)
| 410 | } |
| 411 | }, |
| 412 | async cancel(reason) { |
| 413 | try { |
| 414 | await reader.cancel(reason); |
| 415 | } finally { |
| 416 | reader.releaseLock(); |
| 417 | resolveOutcome({ |
| 418 | applied: 0, |
| 419 | skipped: [], |
| 420 | sync: { status: "pending", applied: 0, skipped: [], error: safeErrorMessage(reason) }, |
| 421 | }); |
| 422 | } |
| 423 | }, |
| 424 | }, |
| 425 | { highWaterMark: 0 }, |
| 426 | ); |
nothing calls this directly
no test coverage detected