Method completeSubscribersUnsafe

packages/effect/src/PubSub.ts:2614–2616

(pubsub: PubSub.Atomic<A>, subscribers: PubSub.Subscribers<A>)

  }

  completeSubscribersUnsafe(pubsub: PubSub.Atomic<A>, subscribers: PubSub.Subscribers<A>): void {
    return strategyCompleteSubscribersUnsafe(this, pubsub, subscribers)
  }

  slidingPublishUnsafe(pubsub: PubSub.Atomic<A>, elements: Iterable<A>): void {
    const it = elements[Symbol.iterator]()