Work in Progress

should be:
```
local go 
go = function()
  ...
  producer:once('end', go)
  ...
end