(result: Result.Result<E, A>)
| 68 | |
| 69 | const interruptedRef = Ref.unsafeMake(false) |
| 70 | const maybeSetResult = (result: Result.Result<E, A>) => |
| 71 | Effect.flatMap( |
| 72 | Ref.get(interruptedRef), |
| 73 | (interrupted) => |
| 74 | interrupted |
| 75 | ? Effect.unit |
| 76 | : Effect.sync(() => this.setResult(result)) |
| 77 | ) |
| 78 | |
| 79 | const fiber = pipe( |
| 80 | Stream.suspend(() => { |