(lockfile: string, key: string)
| 219 | // -- retry wrapper (preserves Handle type) -- |
| 220 | |
| 221 | const acquireHandle = (lockfile: string, key: string): Effect.Effect<Handle, LockError> => |
| 222 | tryAcquireLockDir(lockfile, key).pipe( |
| 223 | Effect.retry({ |
| 224 | while: (err) => err._tag === "NotAcquired", |
| 225 | schedule: retrySchedule, |
| 226 | }), |
| 227 | Effect.catchTag("NotAcquired", () => Effect.fail(new LockTimeoutError({ key }))), |
| 228 | ) |
| 229 | |
| 230 | // -- release -- |
| 231 |
no test coverage detected