Function subscriber

packages/effect/test/SubscriptionRef.test.ts:66–76

(subscriptionRef: SubscriptionRef.SubscriptionRef<number>)

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