public abstract class CsvEntityStreamingSupport extends EntityStreamingSupport
Constructor and Description |
---|
CsvEntityStreamingSupport() |
Modifier and Type | Method and Description |
---|---|
abstract CsvEntityStreamingSupport |
withFramingRendererFlow(org.apache.pekko.stream.javadsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> flow)
Java API: Write-side, apply framing to outgoing entity stream.
|
contentType, csv, csv, framingDecoder, framingRenderer, getFramingDecoder, getFramingRenderer, json, json, parallelism, supported, unordered, withContentType, withParallelMarshalling, withSupported
public abstract CsvEntityStreamingSupport withFramingRendererFlow(org.apache.pekko.stream.javadsl.Flow<org.apache.pekko.util.ByteString,org.apache.pekko.util.ByteString,org.apache.pekko.NotUsed> flow)
Most typical usage will be a variant of Flow[ByteString].intersperse
.
For example for rendering a JSON array one would return
Flow[ByteString].intersperse(ByteString("["), ByteString(","), ByteString("]"))
and for rendering a new-line separated CSV simply Flow[ByteString].intersperse(ByteString("\n"))
.
flow
- (undocumented)