<A, K, V, E2, R2>(
f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>,
options?: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?: Duration.Input | undefined
}
): <E, R>(
self: Stream<A, E, R>
) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
<A, E, R, K, V, E2, R2>(
self: Stream<A, E, R>,
f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>,
options?: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?: Duration.Input | undefined
}
): Stream<readonly [K, Stream<V>], E | E2, R | R2>Groups elements into keyed substreams using an effectful classifier.
Example (Grouping elements into keyed substreams using an effectful classifier)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
const grouped = yield* Stream.make(1, 2, 3, 4, 5).pipe(
Stream.groupBy((n) =>
Effect.succeed([n % 2 === 0 ? "even" : "odd", n] as const)
),
Stream.mapEffect(
Effect.fnUntraced(function*([key, stream]) {
return [key, yield* Stream.runCollect(stream)] as const
}),
{ concurrency: "unbounded" }
),
Stream.runCollect
)
yield* Console.log(grouped)
})
Effect.runPromise(program)
// Output: [ [ "odd", [ 1, 3, 5 ] ], [ "even", [ 2, 4 ] ] ]grouping
Source effect/Stream.ts:826339 lines
export const const groupBy: {
<A, K, V, E2, R2>(
f: (
a: NoInfer<A>
) => Effect.Effect<readonly [K, V], E2, R2>,
options?: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?:
| Duration.Input
| undefined
}
): <E, R>(
self: Stream<A, E, R>
) => Stream<
readonly [K, Stream<V>],
E | E2,
R | R2
>
<A, E, R, K, V, E2, R2>(
self: Stream<A, E, R>,
f: (
a: NoInfer<A>
) => Effect.Effect<readonly [K, V], E2, R2>,
options?: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?:
| Duration.Input
| undefined
}
): Stream<
readonly [K, Stream<V>],
E | E2,
R | R2
>
}
Groups elements into keyed substreams using an effectful classifier.
Example (Grouping elements into keyed substreams using an effectful classifier)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
const grouped = yield* Stream.make(1, 2, 3, 4, 5).pipe(
Stream.groupBy((n) =>
Effect.succeed([n % 2 === 0 ? "even" : "odd", n] as const)
),
Stream.mapEffect(
Effect.fnUntraced(function*([key, stream]) {
return [key, yield* Stream.runCollect(stream)] as const
}),
{ concurrency: "unbounded" }
),
Stream.runCollect
)
yield* Console.log(grouped)
})
Effect.runPromise(program)
// Output: [ [ "odd", [ 1, 3, 5 ] ], [ "even", [ 2, 4 ] ] ]
groupBy: {
<function (type parameter) A in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) K in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) V in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
f: (
a: NoInfer<A>
) => Effect.Effect<readonly [K, V], E2, R2>
a: NoInfer<A>a: type NoInfer<A> = [A][A extends any ? 0 : never]Prevents TypeScript from inferring a type parameter from a specific
position.
When to use
Use when a function parameter must match an inferred type without becoming
an inference source.
Details
The parameter using NoInfer must still match the inferred type.
Example (Controlling inference)
import type { Types } from "effect"
declare function withDefault<T>(value: T, fallback: Types.NoInfer<T>): T
// T is inferred as "a" | "b" from the first argument only
const result = withDefault<"a" | "b">("a", "b")
NoInfer<function (type parameter) A in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
import EffectEffect.type Effect.Effect = /*unresolved*/ anyEffect<readonly [function (type parameter) K in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) V in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
options: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?:
| Duration.Input
| undefined
}
bufferSize?: number | undefinedbufferSize?: number | undefined
readonly idleTimeToLive?: Duration.Input | undefinedidleTimeToLive?: import DurationDuration.type Duration.Input = /*unresolved*/ anyInput | undefined
}
): <function (type parameter) E in <E, R>(self: Stream<A, E, R>): Stream<readonly [K, Stream<V>], E | E2, R | R2>E, function (type parameter) R in <E, R>(self: Stream<A, E, R>): Stream<readonly [K, Stream<V>], E | E2, R | R2>R>(self: Stream<A, E, R>(parameter) self: {
channel: Channel.Channel<Arr.NonEmptyReadonlyArray<A>, E, void, unknown, unknown, unknown, R>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<function (type parameter) A in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <E, R>(self: Stream<A, E, R>): Stream<readonly [K, Stream<V>], E | E2, R | R2>E, function (type parameter) R in <E, R>(self: Stream<A, E, R>): Stream<readonly [K, Stream<V>], E | E2, R | R2>R>) => interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<readonly [function (type parameter) K in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<function (type parameter) V in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <E, R>(self: Stream<A, E, R>): Stream<readonly [K, Stream<V>], E | E2, R | R2>E | function (type parameter) E2 in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R in <E, R>(self: Stream<A, E, R>): Stream<readonly [K, Stream<V>], E | E2, R | R2>R | function (type parameter) R2 in <A, K, V, E2, R2>(f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): <E, R>(self: Stream<A, E, R>) => Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) A in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) K in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) V in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
self: Stream<A, E, R>(parameter) self: {
channel: Channel.Channel<Arr.NonEmptyReadonlyArray<A>, E, void, unknown, unknown, unknown, R>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<function (type parameter) A in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
f: (
a: NoInfer<A>
) => Effect.Effect<readonly [K, V], E2, R2>
a: NoInfer<A>a: type NoInfer<A> = [A][A extends any ? 0 : never]Prevents TypeScript from inferring a type parameter from a specific
position.
When to use
Use when a function parameter must match an inferred type without becoming
an inference source.
Details
The parameter using NoInfer must still match the inferred type.
Example (Controlling inference)
import type { Types } from "effect"
declare function withDefault<T>(value: T, fallback: Types.NoInfer<T>): T
// T is inferred as "a" | "b" from the first argument only
const result = withDefault<"a" | "b">("a", "b")
NoInfer<function (type parameter) A in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
import EffectEffect.type Effect.Effect = /*unresolved*/ anyEffect<readonly [function (type parameter) K in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) V in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
options: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?:
| Duration.Input
| undefined
}
bufferSize?: number | undefinedbufferSize?: number | undefined
readonly idleTimeToLive?: Duration.Input | undefinedidleTimeToLive?: import DurationDuration.type Duration.Input = /*unresolved*/ anyInput | undefined
}
): interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<readonly [function (type parameter) K in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<function (type parameter) V in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
import dualdual((args: anyargs) => const isStream: (
u: unknown
) => u is Stream<unknown, unknown, unknown>
Checks whether a value is a Stream.
Example (Checking whether a value is a Stream)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
const stream = Stream.make(1, 2, 3)
const notStream = { data: [1, 2, 3] }
yield* Console.log(Stream.isStream(stream))
// true
yield* Console.log(Stream.isStream(notStream))
// false
})
Effect.runPromise(program)
isStream(args: anyargs[0]), <function (type parameter) A in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) K in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) V in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
self: Stream<A, E, R>(parameter) self: {
channel: Channel.Channel<Arr.NonEmptyReadonlyArray<A>, E, void, unknown, unknown, unknown, R>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<function (type parameter) A in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
f: (
a: NoInfer<A>
) => Effect.Effect<readonly [K, V], E2, R2>
a: NoInfer<A>a: type NoInfer<A> = [A][A extends any ? 0 : never]Prevents TypeScript from inferring a type parameter from a specific
position.
When to use
Use when a function parameter must match an inferred type without becoming
an inference source.
Details
The parameter using NoInfer must still match the inferred type.
Example (Controlling inference)
import type { Types } from "effect"
declare function withDefault<T>(value: T, fallback: Types.NoInfer<T>): T
// T is inferred as "a" | "b" from the first argument only
const result = withDefault<"a" | "b">("a", "b")
NoInfer<function (type parameter) A in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
import EffectEffect.type Effect.Effect = /*unresolved*/ anyEffect<readonly [function (type parameter) K in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) V in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
options: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?:
| Duration.Input
| undefined
}
bufferSize?: number | undefinedbufferSize?: number | undefined
readonly idleTimeToLive?: Duration.Input | undefinedidleTimeToLive?: import DurationDuration.type Duration.Input = /*unresolved*/ anyInput | undefined
}
): interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<readonly [function (type parameter) K in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
interface Stream<out A, out E = never, out R = never>A Stream<A, E, R> describes a program that can emit many A values, fail
with E, and require R.
Details
Streams are pull-based with backpressure and emit chunks to amortize effect
evaluation. They support monadic composition and error handling similar to
Effect, adapted for multiple values.
Example (Creating and consuming streams)
import { Console, Effect, Stream } from "effect"
const program = Effect.gen(function*() {
yield* Stream.make(1, 2, 3).pipe(
Stream.map((n) => n * 2),
Stream.runForEach((n) => Console.log(n))
)
})
Effect.runPromise(program)
// Output:
// 2
// 4
// 6
Stream<function (type parameter) V in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) E2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
function (type parameter) R2 in <A, E, R, K, V, E2, R2>(self: Stream<A, E, R>, f: (a: NoInfer<A>) => Effect.Effect<readonly [K, V], E2, R2>, options?: {
readonly bufferSize?: number | undefined;
readonly idleTimeToLive?: Duration.Input | undefined;
}): Stream<readonly [K, Stream<V>], E | E2, R | R2>
const groupByImpl: <
A,
E,
R,
K,
V,
E2,
R2
>(
self: Stream<A, E, R>,
f: (
arr: Arr.NonEmptyReadonlyArray<A>,
queues: RcMap.RcMap<
K,
Queue.Queue<V, Cause.Done>
>,
queueMap: MutableHashMap.MutableHashMap<
K,
Queue.Queue<V, Cause.Done>
>
) => Effect.Effect<void, E2, R2>,
options?: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?:
| Duration.Input
| undefined
}
) => Stream<
readonly [K, Stream<V>],
E | E2,
R | R2
>
self: Stream<A, E, R>(parameter) self: {
channel: Channel.Channel<Arr.NonEmptyReadonlyArray<A>, E, void, unknown, unknown, unknown, R>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
import EffectEffect.fnUntraced(function*(arr: any(parameter) arr: {
0: A;
length: number;
toString: () => string;
toLocaleString: { (): string; (locales: string | string[], options?: Intl.NumberFormatOptions & Intl.DateTimeFormatOptions): string };
concat: { (...items: Array<ConcatArray<A>>): Array<A>; (...items: Array<A | ConcatArray<A>>): Array<A> };
join: (separator?: string) => string;
slice: (start?: number, end?: number) => Array<A>;
indexOf: (searchElement: A, fromIndex?: number) => number;
lastIndexOf: (searchElement: A, fromIndex?: number) => number;
every: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): this is readonly S[]; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): boolean };
some: (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any) => boolean;
forEach: (callbackfn: (value: A, index: number, array: ReadonlyArray<A>) => void, thisArg?: any) => void;
map: (callbackfn: (value: A, index: number, array: ReadonlyArray<A>) => U, thisArg?: any) => Array<U>;
filter: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): Array<S>; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): Array<A> };
reduce: { (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A): A; (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A, initialValue: A): A; (callbac…;
reduceRight: { (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A): A; (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A, initialValue: A): A; (callbac…;
find: { (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => value is S, thisArg?: any): S | undefined; (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => unknown, thisArg?: any): A | undefined };
findIndex: (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => unknown, thisArg?: any) => number;
entries: () => ArrayIterator<[number, A]>;
keys: () => ArrayIterator<number>;
values: () => ArrayIterator<A>;
includes: (searchElement: A, fromIndex?: number) => boolean;
flatMap: (callback: (this: This, value: A, index: number, array: Array<A>) => U | ReadonlyArray<U>, thisArg?: This | undefined) => Array<U>;
flat: (this: A, depth?: D | undefined) => Array<FlatArray<A, D>>;
at: (index: number) => A | undefined;
findLast: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): S | undefined; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): A | undefined };
findLastIndex: (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any) => number;
toReversed: () => Array<A>;
toSorted: (compareFn?: ((a: A, b: A) => number) | undefined) => Array<A>;
toSpliced: { (start: number, deleteCount: number, ...items: Array<A>): Array<A>; (start: number, deleteCount?: number): Array<A> };
with: (index: number, value: A) => Array<A>;
}
queues: RcMap.RcMap<
K,
Queue.Queue<V, Cause.Done<void>>,
never
>
(parameter) queues: {
lookup: (key: K) => Effect.Effect<A, E, Scope.Scope>;
context: Context.Context<never>;
scope: Scope.Scope;
idleTimeToLive: (key: K) => Duration.Duration;
capacity: number;
state: State<K, A, E>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
queueMap: MutableHashMap.MutableHashMap<
K,
Queue.Queue<V, Cause.Done<void>>
>
(parameter) queueMap: {
backing: Map<K, V>;
buckets: Map<number, NonEmptyArray<K>>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
toString: () => string;
toJSON: () => unknown;
}
let i: numberi = 0; let i: numberi < arr: any(parameter) arr: {
0: A;
length: number;
toString: () => string;
toLocaleString: { (): string; (locales: string | string[], options?: Intl.NumberFormatOptions & Intl.DateTimeFormatOptions): string };
concat: { (...items: Array<ConcatArray<A>>): Array<A>; (...items: Array<A | ConcatArray<A>>): Array<A> };
join: (separator?: string) => string;
slice: (start?: number, end?: number) => Array<A>;
indexOf: (searchElement: A, fromIndex?: number) => number;
lastIndexOf: (searchElement: A, fromIndex?: number) => number;
every: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): this is readonly S[]; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): boolean };
some: (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any) => boolean;
forEach: (callbackfn: (value: A, index: number, array: ReadonlyArray<A>) => void, thisArg?: any) => void;
map: (callbackfn: (value: A, index: number, array: ReadonlyArray<A>) => U, thisArg?: any) => Array<U>;
filter: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): Array<S>; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): Array<A> };
reduce: { (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A): A; (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A, initialValue: A): A; (callbac…;
reduceRight: { (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A): A; (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A, initialValue: A): A; (callbac…;
find: { (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => value is S, thisArg?: any): S | undefined; (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => unknown, thisArg?: any): A | undefined };
findIndex: (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => unknown, thisArg?: any) => number;
entries: () => ArrayIterator<[number, A]>;
keys: () => ArrayIterator<number>;
values: () => ArrayIterator<A>;
includes: (searchElement: A, fromIndex?: number) => boolean;
flatMap: (callback: (this: This, value: A, index: number, array: Array<A>) => U | ReadonlyArray<U>, thisArg?: This | undefined) => Array<U>;
flat: (this: A, depth?: D | undefined) => Array<FlatArray<A, D>>;
at: (index: number) => A | undefined;
findLast: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): S | undefined; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): A | undefined };
findLastIndex: (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any) => number;
toReversed: () => Array<A>;
toSorted: (compareFn?: ((a: A, b: A) => number) | undefined) => Array<A>;
toSpliced: { (start: number, deleteCount: number, ...items: Array<A>): Array<A>; (start: number, deleteCount?: number): Array<A> };
with: (index: number, value: A) => Array<A>;
}
let i: numberi++) {
const [const key: anykey, const value: anyvalue] = yield* f: (
a: NoInfer<A>
) => Effect.Effect<readonly [K, V], E2, R2>
arr: any(parameter) arr: {
0: A;
length: number;
toString: () => string;
toLocaleString: { (): string; (locales: string | string[], options?: Intl.NumberFormatOptions & Intl.DateTimeFormatOptions): string };
concat: { (...items: Array<ConcatArray<A>>): Array<A>; (...items: Array<A | ConcatArray<A>>): Array<A> };
join: (separator?: string) => string;
slice: (start?: number, end?: number) => Array<A>;
indexOf: (searchElement: A, fromIndex?: number) => number;
lastIndexOf: (searchElement: A, fromIndex?: number) => number;
every: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): this is readonly S[]; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): boolean };
some: (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any) => boolean;
forEach: (callbackfn: (value: A, index: number, array: ReadonlyArray<A>) => void, thisArg?: any) => void;
map: (callbackfn: (value: A, index: number, array: ReadonlyArray<A>) => U, thisArg?: any) => Array<U>;
filter: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): Array<S>; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): Array<A> };
reduce: { (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A): A; (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A, initialValue: A): A; (callbac…;
reduceRight: { (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A): A; (callbackfn: (previousValue: A, currentValue: A, currentIndex: number, array: ReadonlyArray<A>) => A, initialValue: A): A; (callbac…;
find: { (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => value is S, thisArg?: any): S | undefined; (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => unknown, thisArg?: any): A | undefined };
findIndex: (predicate: (value: A, index: number, obj: ReadonlyArray<A>) => unknown, thisArg?: any) => number;
entries: () => ArrayIterator<[number, A]>;
keys: () => ArrayIterator<number>;
values: () => ArrayIterator<A>;
includes: (searchElement: A, fromIndex?: number) => boolean;
flatMap: (callback: (this: This, value: A, index: number, array: Array<A>) => U | ReadonlyArray<U>, thisArg?: This | undefined) => Array<U>;
flat: (this: A, depth?: D | undefined) => Array<FlatArray<A, D>>;
at: (index: number) => A | undefined;
findLast: { (predicate: (value: A, index: number, array: ReadonlyArray<A>) => value is S, thisArg?: any): S | undefined; (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any): A | undefined };
findLastIndex: (predicate: (value: A, index: number, array: ReadonlyArray<A>) => unknown, thisArg?: any) => number;
toReversed: () => Array<A>;
toSorted: (compareFn?: ((a: A, b: A) => number) | undefined) => Array<A>;
toSpliced: { (start: number, deleteCount: number, ...items: Array<A>): Array<A>; (start: number, deleteCount?: number): Array<A> };
with: (index: number, value: A) => Array<A>;
}
let i: numberi])
const const oentry: Option.Option<
Queue.Queue<V, Cause.Done<void>>
>
import MutableHashMapMutableHashMap.get(queueMap: MutableHashMap.MutableHashMap<
K,
Queue.Queue<V, Cause.Done<void>>
>
(parameter) queueMap: {
backing: Map<K, V>;
buckets: Map<number, NonEmptyArray<K>>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
toString: () => string;
toJSON: () => unknown;
}
const key: anykey)
const const queue: Queue.Queue<
V,
Cause.Done<void>
>
const queue: {
strategy: "suspend" | "dropping" | "sliding";
dispatcher: SchedulerDispatcher;
capacity: number;
messages: MutableList.MutableList<any>;
state: Queue.State<any, any>;
scheduleRunning: boolean;
toString: () => string;
toJSON: () => unknown;
}
import OptionOption.isSome(const oentry: Option.Option<
Queue.Queue<V, Cause.Done<void>>
>
const oentry: Option.Some<
Queue.Queue<V, Cause.Done<void>>
>
const oentry: {
_tag: "Some";
_op: "Some";
value: A;
valueOrUndefined: A;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
toString: () => string;
toJSON: () => unknown;
}
import EffectEffect.scoped(import RcMapRcMap.get(queues: RcMap.RcMap<
K,
Queue.Queue<V, Cause.Done<void>>,
never
>
(parameter) queues: {
lookup: (key: K) => Effect.Effect<A, E, Scope.Scope>;
context: Context.Context<never>;
scope: Scope.Scope;
idleTimeToLive: (key: K) => Duration.Duration;
capacity: number;
state: State<K, A, E>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
const key: anykey))
yield* import RcMapRcMap.touch(queues: RcMap.RcMap<
K,
Queue.Queue<V, Cause.Done<void>>,
never
>
(parameter) queues: {
lookup: (key: K) => Effect.Effect<A, E, Scope.Scope>;
context: Context.Context<never>;
scope: Scope.Scope;
idleTimeToLive: (key: K) => Duration.Duration;
capacity: number;
state: State<K, A, E>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
const key: anykey)
yield* import QueueQueue.offer(const queue: Queue.Queue<
V,
Cause.Done<void>
>
const queue: {
strategy: "suspend" | "dropping" | "sliding";
dispatcher: SchedulerDispatcher;
capacity: number;
messages: MutableList.MutableList<any>;
state: Queue.State<any, any>;
scheduleRunning: boolean;
toString: () => string;
toJSON: () => unknown;
}
const value: anyvalue)
}
}),
options: {
readonly bufferSize?: number | undefined
readonly idleTimeToLive?:
| Duration.Input
| undefined
}