aboutsummaryrefslogtreecommitdiff
path: root/gem/ex10.lua
blob: 2b1b98f2f0de203e0b97b23b62f8e83cead1abef (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
function pump.step(src, snk)
  local chunk, src_err = src()
  local ret, snk_err = snk(chunk, src_err)
  if chunk and ret then return 1
  else return nil, src_err or snk_err end
end

function pump.all(src, snk, step)
    step = step or pump.step
    while true do
        local ret, err = step(src, snk)
        if not ret then
            if err then return nil, err
            else return 1 end
        end
    end
end