Finalize on the async lane.
Awaits every task started via StreamTransformer.schedule()
across all transformers, then calls afinalize() on each,
then auto-closes channels and the main event log.
If any scheduled task raised under on_error="raise", or any
transformer's afinalize raises, the exception propagates.
The caller (the pump) handles it by routing into afail.
