Add step init

1 files changed, 2 insertions, 2 deletions

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