스트림

효율적인 데이터 처리를 위한 스트림 읽기/쓰기 작업. 스트림 객체는 다른 모듈(HTTP, 파일시스템 등)에서 얻습니다.

로딩

-- HTTP 요청 본문에서
local stream = req:stream()

-- 파일시스템에서
local fs = require("fs")
local stream = fs.get("app:data"):open("/file.txt", "r")

읽기

local chunk, err = stream:read(size)

반환: string, error - EOF에서 nil

-- 남은 모든 데이터 읽기
local data, err = stream:read_all()

쓰기

local bytes, err = stream:write(data)

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

탐색

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

반환: integer, error - 새 위치

플러시

local ok, err = stream:flush()

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

스트림 정보

local info, err = stream:stat()

닫기

local ok, err = stream:close()

스트림을 닫고 리소스를 해제합니다. 여러 번 호출해도 안전합니다.

스캐너

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

local scanner, err = stream:scanner(split)

스캐너 메서드

local has_more = scanner:scan()  -- 다음 토큰으로 진행
local token = scanner:text()      -- 현재 토큰 가져오기
local err_msg = scanner:err()     -- 에러가 있으면 가져오기

while scanner:scan() do
    local line = scanner:text()
    process(line)
end
if scanner:err() then
    return nil, errors.new("INTERNAL", scanner:err())
end

에러