스트림

stream은 HTTP, filesystem 및 기타 module에 incremental I/O를 제공합니다. underlying data를 소유한 module이 stream object를 생성합니다. 이 페이지는 API reference이며 scanner loop는 application-defined process(token) callback을 사용합니다.

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

읽기

local chunk, err = stream:read(size)

반환: string, error — EOF에서 nil, nil

쓰기

local bytes, err = stream:write(data)

반환: integer, error - 쓴 바이트 수

탐색

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

반환: integer, error - 새 위치

플러시

local ok, err = stream:flush()

flush는 버퍼링된 데이터를 기본 대상으로 기록합니다.

버퍼된 데이터를 기본 스토리지로 플러시합니다.

스트림 정보

local info, err = stream:stat()

닫기

local ok, err = stream:close()

close는 stream resource를 release하며 두 번 이상 호출할 수 있습니다.

스캐너

스트림 콘텐츠를 위한 토크나이저 생성:

local scanner, err = stream:scanner(split)

스캐너 메서드

local has_more, err = scanner:scan()  -- 다음 토큰으로 진행
local token = scanner:text()           -- 현재 토큰
local err_msg = scanner:err()          -- 스캐너 에러(있는 경우)

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

scan()이 false를 반환하면 EOF로 처리하기 전에 scanner:err()를 확인하십시오. tokenization과 underlying read failure는 scanner에 저장되며 scan()의 second return value에는 나타나지 않습니다.

에러