Transform stream through a processing function
Provides a streaming transform pattern that maintains backpressure and handles errors gracefully.
Input async iterable
Transform function to apply to each item
Transformed items
If transformation fails
Transform stream through a processing function
Provides a streaming transform pattern that maintains backpressure and handles errors gracefully.