stream

open override fun stream(query: ListQuery, caller: QueryCaller, after: String? = null, chunkSize: Int = DEFAULT_STREAM_CHUNK_SIZE): Flow<PositionedRecord>

The records query matches as a resumable stream: keyset chunks of chunkSize records read one after the other, each record with the cursor token of its position, from strictly after the position after names when given. after is a token of this model and effective sort (a stream's or a cursor query's); any other is wow.query.invalid. The query is admitted like a cursor query, so a stream resumed with the same query from another node or after a restart reads on from the same place, under its caller's scope again; at most query's limit records are read (0: all of them), and its budget bounds neither the limit nor the chunks. Each chunk runs within the query's timeout and under one bulkhead permit, given back before its records are emitted. Chunks are not one snapshot: see chunks. Only for a query resumes.