diff --git a/src/Sink.ts b/src/Sink.ts index 7a23769..682db24 100644 --- a/src/Sink.ts +++ b/src/Sink.ts @@ -986,6 +986,7 @@ export const fromEffect: (effect: Effect.Effect) => Sink( /** * Create a sink which enqueues each element into the specified queue. * + * @param shutdown If `true`, the queue will be shutdown after the sink is evaluated (defaults to `false`) * @since 1.0.0 * @category constructors */ diff --git a/src/Stream.ts b/src/Stream.ts index 5b2d1a5..fee9857 100644 --- a/src/Stream.ts +++ b/src/Stream.ts @@ -1435,6 +1435,7 @@ export const fromChunk: (chunk: Chunk.Chunk) => Stream = /** * Creates a stream from a subscription to a `Hub`. * + * @param shutdown If `true`, the hub will be shutdown after the stream is evaluated (defaults to `false`) * @since 1.0.0 * @category constructors */ @@ -1452,6 +1453,7 @@ export const fromChunkHub: { /** * Creates a stream from a `Queue` of values. * + * @param shutdown If `true`, the queue will be shutdown after the stream is evaluated (defaults to `false`) * @since 1.0.0 * @category constructors */ @@ -1490,6 +1492,7 @@ export const fromEffectOption: (effect: Effect.Effect( * Creates a stream from a queue of values * * @param maxChunkSize The maximum number of queued elements to put in one chunk in the stream + * @param shutdown If `true`, the queue will be shutdown after the stream is evaluated (defaults to `false`) * @since 1.0.0 * @category constructors */