stream

open override fun stream(query: AdmittedQuery<ListQuery>): Flow<ObjectNode>

The records of query, read in full in their transaction, which then ends and gives its connection back, and only then emitted: a consumer as slow as an SSE client's never holds a connection of the pool the log appends through. The admission bounds the list (maxListSize); a budget without that bound (maxListSize = 0) holds a whole unbounded list in memory.