(self: TxEnqueue<A, E>)
| 1357 | * @since 2.0.0 |
| 1358 | */ |
| 1359 | export const shutdown = <A, E>(self: TxEnqueue<A, E>): Effect.Effect<boolean> => |
| 1360 | Effect.gen(function*() { |
| 1361 | yield* Effect.ignoreCause(clear(self)) |
| 1362 | return yield* interrupt(self) |
| 1363 | }).pipe(Effect.tx) |
| 1364 | |
| 1365 | /** |
| 1366 | * Checks whether the queue is in the open state. |