fastify-reply-from with transform stream

I wrote the code differently, but in all ways, the GET request from the client hangs forever.
However, sending the reply without any transformation return reply.from(url) works as expected.

the command curl http://localhost:3000/?url=http://localhost:5050 from inside the server does not return any response either.

any1 have an idea, why it's not working with me?
Thanks a lot

here are two examples where the GET request is stuck forever:

'use strict'
 
const { Transform, pipeline } = require('stream')
 
function upper() {
  return new Transform({
    transform(chunk, encoding, callback) {
      callback(null, chunk.toString().toUpperCase())
    }
  })
}
 
module.exports = async function (fastify, opts) {
  fastify.get('/', async function (request, reply) {
    const { url } = request.query
    try {
      new URL(url)
    } catch (err) {
      throw fastify.httpErrors.badRequest()
    }
    console.log('Fetching from URL:', url)
    return reply.from(url, {
      onResponse (request, reply, res) { 
        console.log('Received response from upstream URL')
        pipeline(res, upper(), reply.raw,
          (err) => {
            if (err) {
              console.error('Pipeline failed:', err)
              reply.code(500).send({ error: 'Internal Server Error' })
            } else {
              console.log('Pipeline succeeded')
            }
          }
        )
      }
    })
  })
}

The original code as in the course also beating the same with me:

'use strict'
const { Readable } = require('stream')
async function * upper (res) {
  for await (const chunk of res) {
    yield chunk.toString().toUpperCase()
  }
}
module.exports = async function (fastify, opts) {
  fastify.get('/', async function (request, reply) {
    const { url } = request.query
    try {
      new URL(url)
    } catch (err) {
      throw fastify.httpErrors.badRequest()
    }
    return reply.from(url, {
      onResponse (request, reply, res) {
        reply.send(Readable.from(upper(res)))
      }
    })
  })
}

It should be reply.send(Readable.from(upper(res.stream))), probably the plugin has changed and the stream is part or res.