org.apache.pekko.http.javadsl.common

Class CsvEntityStreamingSupport

java.lang.Object

org.apache.pekko.http.javadsl.common.EntityStreamingSupport

org.apache.pekko.http.scaladsl.common.EntityStreamingSupport

org.apache.pekko.http.javadsl.common.CsvEntityStreamingSupport

Direct Known Subclasses:

CsvEntityStreamingSupport

public abstract class CsvEntityStreamingSupport
extends EntityStreamingSupport

Constructor Summary

Constructors

Constructor and Description
CsvEntityStreamingSupport()

Method Summary

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.

Methods inherited from class org.apache.pekko.http.scaladsl.common.EntityStreamingSupport

contentType, csv, csv, framingDecoder, framingRenderer, getFramingDecoder, getFramingRenderer, json, json, parallelism, supported, unordered, withContentType, withParallelMarshalling, withSupported

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CsvEntityStreamingSupport

public CsvEntityStreamingSupport()

Method Detail

withFramingRendererFlow

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)

Java API: Write-side, apply framing to outgoing entity stream.

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")).

Parameters:

flow - (undocumented)

Returns:

(undocumented)