Streams

Streams fornecem I/O incremental para HTTP, filesystem e outros módulos. Os módulos proprietários dos dados subjacentes criam os objetos stream. Esta página é uma referência de API; o loop do scanner usa um callback process(token) definido pela aplicação.

Obtendo um Stream

-- From HTTP request body
local stream, err = req:stream()
if err then return nil, err end

-- From filesystem
local fs = require("fs")
local volume, err = fs.get("app:data")
if err then return nil, err end

local stream, err = volume:open("/file.txt", "r")
if err then return nil, err end

Leitura

local chunk, err = stream:read(size)

Retorna: string, error — nil, nil em EOF

Escrita

local bytes, err = stream:write(data)

Retorna: integer, error — bytes escritos

Seeking

local pos, err = stream:seek(whence, offset)

Retorna: integer, error — nova posicao

Flushing

local ok, err = stream:flush()

flush grava os dados em buffer no destino subjacente.

Informações do Stream

local info, err = stream:stat()

Fechando

local ok, err = stream:close()

close libera os recursos do stream e pode ser chamado mais de uma vez.

Scanner

Crie um scanner que tokeniza o conteúdo do stream:

local scanner, err = stream:scanner(split)

Métodos do Scanner

local has_more, err = scanner:scan()  -- avancar para o proximo token
local token = scanner:text()           -- token atual
local err_msg = scanner:err()          -- erro do scanner, se houver

while true do
    local has_token, err = scanner:scan()
    if err then return nil, err end
    if not has_token then break end  -- EOF
    process(scanner:text())
end

Quando scan() retorna false, verifique scanner:err() antes de tratar o resultado como EOF. Falhas de tokenização e de leitura subjacente ficam armazenadas no scanner e não aparecem no segundo valor retornado por scan().

Erros