Hyperlinkv0.8.0-beta.28

Stream

Stream.zipRightconsteffect/Stream.ts:3766
<AR, ER, RR>(right: Stream<AR, ER, RR>): <AL, EL, RL>(
  left: Stream<AL, EL, RL>
) => Stream<AR, ER | EL, RR | RL>
<AL, EL, RL, AR, ER, RR>(
  left: Stream<AL, EL, RL>,
  right: Stream<AR, ER, RR>
): Stream<AR, EL | ER, RL | RR>

Zips this stream with another point-wise, keeping only right values and ending when either stream ends.

Example (Zipping streams while keeping right values)

import { Console, Effect, Stream } from "effect"

const stream1 = Stream.make(1, 2)
const stream2 = Stream.make("a", "b", "c", "d")

const program = Effect.gen(function*() {
  const result = yield* Stream.zipRight(stream1, stream2).pipe(Stream.runCollect)
  yield* Console.log(result)
})

Effect.runPromise(program)
// Output: ["a", "b"]
zipping
Source effect/Stream.ts:376618 lines
export const zipRight: {
  <AR, ER, RR>(right: Stream<AR, ER, RR>): <AL, EL, RL>(left: Stream<AL, EL, RL>) => Stream<AR, ER | EL, RR | RL>
  <AL, EL, RL, AR, ER, RR>(left: Stream<AL, EL, RL>, right: Stream<AR, ER, RR>): Stream<AR, EL | ER, RL | RR>
} = dual(
  2,
  <AL, EL, RL, AR, ER, RR>(
    left: Stream<AL, EL, RL>,
    right: Stream<AR, ER, RR>
  ): Stream<AR, EL | ER, RL | RR> =>
    zipWithArray(left, right, (leftArr, rightArr) => {
      const minLength = Math.min(leftArr.length, rightArr.length)
      const output = rightArr.slice(0, minLength) as Arr.NonEmptyArray<AR>
      const leftoverLeft = leftArr.slice(minLength)
      const leftoverRight = rightArr.slice(minLength)

      return [output, leftoverLeft, leftoverRight] as const
    })
)