From a4ec6d0aa7b9f43866fbb91326595972e732253a Mon Sep 17 00:00:00 2001 From: Yuval Adam <_@yuv.al> Date: Fri, 21 Mar 2025 22:51:42 +0100 Subject: Add step init --- README.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'README.md') diff --git a/README.md b/README.md index 08becf1..9b9d744 100644 --- a/README.md +++ b/README.md @@ -27,8 +27,8 @@ async def main(): async for out in pipe: print(out) - # or collect them all - res = await pipe.collect() + # or just single line it and collect them all + res = await Pipeline(source(), double, batch, sum).collect() ``` ## License -- cgit v1.3.1