Streams

Streams bieten inkrementelles I/O für HTTP-, Dateisystem- und andere Module. Die Module, denen die zugrunde liegenden Daten gehören, erstellen die Stream-Objekte. Diese Seite ist eine API-Referenz; die Scanner-Schleife verwendet einen anwendungsdefinierten Callback process(token).

Einen Stream beziehen

-- 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

Lesen

local chunk, err = stream:read(size)

Gibt zurück: string, error — nil, nil bei EOF

Schreiben

local bytes, err = stream:write(data)

Gibt zurück: integer, error — geschriebene Bytes

Positionieren

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

Gibt zurück: integer, error — neue Position

Flushen

local ok, err = stream:flush()

flush schreibt gepufferte Daten in das zugrunde liegende Ziel.

Stream-Info

local info, err = stream:stat()

Schließen

local ok, err = stream:close()

close gibt die Ressourcen des Streams frei und kann mehrfach aufgerufen werden.

Scanner

Tokenizer für Stream-Inhalt erstellen:

local scanner, err = stream:scanner(split)

Scanner-Methoden

local has_more, err = scanner:scan()  -- Zum nächsten Token vorrücken
local token = scanner:text()           -- Aktuelles Token
local err_msg = scanner:err()          -- Scanner-Fehler falls vorhanden

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

Wenn scan() den Wert false zurückgibt, prüfen Sie scanner:err(), bevor Sie das Ergebnis als EOF behandeln. Tokenisierungsfehler und Fehler beim zugrunde liegenden Lesen werden im Scanner gespeichert und erscheinen nicht im zweiten Rückgabewert von scan().

Fehler