c.lua

local levee = require("levee")
local _ = levee._


local h = levee.Hub()

local r, w = h.io:pipe()

h:spawn(function()
	for i = 1, 1000 do
		local s = tostring(i):rep(i)
		w:write(s)
	end
	w:close()
end)


local buf = levee.d.Buffer(4096)
while true do
	buf:ensure()
	local err, n = r:read(buf.buf + buf.len, buf.cap - buf.len)
	if err then break end
	buf.len = buf.len + n
end