static final class HttpStreamResult.LinePublisher
extends Object
implements Flow.Publisher<String>
Adapts a chunked byte publisher into a publisher of complete lines.
Buffers across chunk boundaries so multi-chunk lines emit correctly,
and honours downstream demand — a single upstream chunk containing
many newlines is drip-fed to the downstream one line per request.
| Constructor and description |
|---|
LinePublisher(Flow.Publisher<List<ByteBuffer>> source, Charset charset)Creates a publisher that emits complete lines decoded from byte chunks. |
Creates a publisher that emits complete lines decoded from byte chunks.
source - the upstream byte-chunk publishercharset - the charset used for decoding bytesCopyright © 2003-2026 The Apache Software Foundation. All rights reserved.