aboutsummaryrefslogtreecommitdiff
path: root/gem/ex10.lua
diff options
context:
space:
mode:
Diffstat (limited to 'gem/ex10.lua')
-rw-r--r--gem/ex10.lua17
1 files changed, 17 insertions, 0 deletions
diff --git a/gem/ex10.lua b/gem/ex10.lua
new file mode 100644
index 0000000..2b1b98f
--- /dev/null
+++ b/gem/ex10.lua
@@ -0,0 +1,17 @@
1function pump.step(src, snk)
2 local chunk, src_err = src()
3 local ret, snk_err = snk(chunk, src_err)
4 if chunk and ret then return 1
5 else return nil, src_err or snk_err end
6end
7
8function pump.all(src, snk, step)
9 step = step or pump.step
10 while true do
11 local ret, err = step(src, snk)
12 if not ret then
13 if err then return nil, err
14 else return 1 end
15 end
16 end
17end