(exit: Exit<void, E>)
| 198 | return this.done(core.exitFailCause(cause)) |
| 199 | } |
| 200 | unsafeDone(exit: Exit<void, E>): boolean { |
| 201 | if (this.state._tag !== "Open") { |
| 202 | return false |
| 203 | } else if (this.state.offers.size === 0 && this.messages.length === 0 && this.messagesChunk.length === 0) { |
| 204 | this.finalize(exit) |
| 205 | return true |
| 206 | } |
| 207 | this.state = { ...this.state, _tag: "Closing", exit } |
| 208 | return true |
| 209 | } |
| 210 | shutdown: Effect<boolean> = core.sync(() => { |
| 211 | if (this.state._tag === "Done") { |
| 212 | return true |
no test coverage detected