`pipeline` utility does not work with all commands

    async function* test(stream) {
        for await (const chunk of stream) {
            console.log(chunk)
            yield chunk
        }
    }

    const pt = new PassThrough()

    ffmpeg(SOURCE)
        .outputFPS(FPS)
        .size(`${WIDTH}x${HEIGHT}`)
        .videoCodec('ppm')
        .withNoAudio()
        .outputFormat('image2pipe')
        .stream(pt, { end: true })

    pipeline(
       pt,
       test,
       err => console.log(err)
    )

  const pt = new PassThrough()

    ffmpeg(SOURCE)
        .outputFPS(FPS)
        .size(`${WIDTH}x${HEIGHT}`)
        .videoCodec('ppm')
        .withNoAudio()
        .outputFormat('image2pipe')
        .stream(pt, { end: true })
        
        pt.pipe(new Transform({transform(chunk, encoding, callback) {
        console.log(chunk); callback();
        }}))