(
pubsub: PubSub.Atomic<A>,
subscribers: PubSub.Subscribers<A>,
elements: Iterable<A>,
_isShutdown: MutableRef.MutableRef<boolean>
)
| 2583 | } |
| 2584 | |
| 2585 | handleSurplus( |
| 2586 | pubsub: PubSub.Atomic<A>, |
| 2587 | subscribers: PubSub.Subscribers<A>, |
| 2588 | elements: Iterable<A>, |
| 2589 | _isShutdown: MutableRef.MutableRef<boolean> |
| 2590 | ): Effect.Effect<boolean> { |
| 2591 | return Effect.sync(() => { |
| 2592 | this.slidingPublishUnsafe(pubsub, elements) |
| 2593 | this.completeSubscribersUnsafe(pubsub, subscribers) |
| 2594 | return true |
| 2595 | }) |
| 2596 | } |
| 2597 | |
| 2598 | onPubSubEmptySpaceUnsafe( |
| 2599 | _pubsub: PubSub.Atomic<A>, |
nothing calls this directly
no test coverage detected