It seems like the Transform.from() returns a duplex stream rather than a transform stream because the Transform class is a subclass of Duplex class which is where the .from method is being inherited from.

slightly related answer https://stackoverflow.com/a/62008680/9763688

Also, when a new Transform object is instantiated, the error is being captured by the catch block properly similar to using an AsyncGeneratorFunction.

Maybe a duplex stream created from Transform.from() isn't intended to be used in the pipeline function(causing some unexpected behavior; which seems like an incomplete implementation)??

@Ryuollojy if you found the answer, please share it here, thanks.