Function fromTQueue

packages/effect/src/internal/stream.ts:3210–3225

(queue: TQueue.TDequeue<A>)

/** @internal */
export const fromTQueue = <A>(queue: TQueue.TDequeue<A>): Stream.Stream<A> =>
  pipe(
    TQueue.take(queue),
    Effect.map(Chunk.of),
    Effect.catchAllCause((cause) =>
      pipe(
        TQueue.isShutdown(queue),
        Effect.flatMap((isShutdown) =>
          isShutdown && Cause.isInterrupted(cause) ?
            pull.end() :
            pull.failCause(cause)
        )
      )
    ),
    repeatEffectChunkOption
  )

/** @internal */
export const fromSchedule = <A, R>(schedule: Schedule.Schedule<A, unknown, R>): Stream.Stream<A, never, R> =>