Bounded async pipeline

Implement async def pipeline(items, transform, workers=2, maxsize=3): - put all items through an asyncio.Queue(maxsize=maxsize) - workers async tasks consume and append await transform(item) results - the producer must NOT dump everything into the queue at once — with maxsize honored, queue backpressure applies (await q.put suspends when full) - return sorted(results) after await q.join(); cancel the workers afterwards