()
| 1161 | } |
| 1162 | |
| 1163 | get shutdown(): Effect.Effect<void> { |
| 1164 | return core.uninterruptible(core.withFiberRuntime((state) => { |
| 1165 | pipe(this.shutdownFlag, MutableRef.set(true)) |
| 1166 | return pipe( |
| 1167 | this.scope.close(core.exitInterrupt(state.id())), |
| 1168 | core.zipRight(this.strategy.shutdown), |
| 1169 | core.whenEffect(core.deferredSucceed(this.shutdownHook, void 0)), |
| 1170 | core.asVoid |
| 1171 | ) |
| 1172 | })) |
| 1173 | } |
| 1174 | |
| 1175 | publish(value: A): Effect.Effect<boolean> { |
| 1176 | return core.suspend(() => { |