Function subscriber

packages/effect/test/TSubscriptionRef.test.ts:129–139

(subscriptionRef: TSubscriptionRef.TSubscriptionRef<number>)

  it.effect("concurrent subscribes and unsubscribes are handled correctly", () =>
    Effect.gen(function*() {
      const subscriber = (subscriptionRef: TSubscriptionRef.TSubscriptionRef<number>) =>
        pipe(
          Random.nextIntBetween(0, 200),
          Effect.flatMap((n) =>
            pipe(
              TSubscriptionRef.changesStream(subscriptionRef),
              Stream.take(n),
              Stream.runCollect
            )
          )
        )
      const ref = yield* (TSubscriptionRef.make(0))
      const fiber = yield* pipe(
        TSubscriptionRef.update(ref, (n) => n + 1),