`Stream.zip` for more than two streams

[nounder]

What version of Effect is running?

3.6.0

What steps can reproduce the bug?

import { Effect, Stream } from "effect"

const stream = Stream.make(1, 2, 3).pipe(
	Stream.broadcast(3, 10),
	Stream.map(([s1, s2, s3]) => ({
		n1: s1,
		n2: s2.pipe(Stream.map((v) => v * 2)),
		n3: s2.pipe(Stream.map((v) => v * 3)),
	})),
	Stream.flatMap(({ n1, n2, n3 }) =>
		Stream.zip(n1, n2, n3), // TYPESCRIPT REPORTS: Expected 1-2 arguments, but got 3. ts (2554) [11, 22]
	),
)

Effect.runPromise(Stream.runCollect(stream)).then(console.log)

What is the expected behavior?

Passing more than 2 streams to Stream.zip works per documentation :

Zipping is a process of combining two or more streams to create a new stream by pairing elements from the input streams.

What do you see instead?

Expected 1-2 arguments, but got 3. ts (2554) [11, 22]

when passing more than 2 streams to Stream.zip

Additional information

No response

[nounder]

Here's workaround using Effect.all:

import { Effect, Stream } from "effect"

const stream = Stream.make(1, 2, 3).pipe(
	Stream.mapEffect((v) =>
		Effect.all(
			{
				n1: Effect.succeed(v),
				n2: Effect.succeed(v * 2),
				n3: Effect.succeed(v * 3),
			},
			{ concurrency: "unbounded" },
		),
	),
)

Effect.runPromise(Stream.runCollect(stream)).then(console.log)

Unfortunately, this makes consuming stream slower because it has to wait for all effects to finalize for each element.

[mikearnaldi]

Seems like we are missing a Stream.all