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
	local err = r:readinto(buf)
	if err then break end
end