(effect: Effect.Effect<any, any, any>)
| 1055 | ) { |
| 1056 | let alreadyCalled = false |
| 1057 | const callback = (effect: Effect.Effect<any, any, any>) => { |
| 1058 | if (!alreadyCalled) { |
| 1059 | alreadyCalled = true |
| 1060 | this.tell(FiberMessage.resume(effect)) |
| 1061 | } |
| 1062 | } |
| 1063 | if (runtimeFlags_.interruptible(runtimeFlags)) { |
| 1064 | this._asyncInterruptor = callback |
| 1065 | } |