(self: TxQueueState)
| 1111 | * @since 2.0.0 |
| 1112 | */ |
| 1113 | export const isFull = (self: TxQueueState): Effect.Effect<boolean> => |
| 1114 | self.capacity === Number.POSITIVE_INFINITY |
| 1115 | ? Effect.succeed(false) |
| 1116 | : Effect.map(size(self), (currentSize) => currentSize >= self.capacity) |
| 1117 | |
| 1118 | /** |
| 1119 | * Interrupts the queue gracefully with the current fiber's interruption cause. |