c.lua

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

local h = levee.Hub()

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

h:spawn(function()
	w:write(("X"):rep(16*1024*1024))
	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

	print(buf.len)
end

print("here")