akka.stream.impl.io.compression

Class CompressionUtils

java.lang.Object

akka.stream.impl.io.compression.CompressionUtils

public class CompressionUtils
extends java.lang.Object

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
CompressionUtils()

Method Summary

Modifier and Type	Method and Description
static Flow<ByteString,ByteString,NotUsed>	compressorFlow(scala.Function0<Compressor> newCompressor) Creates a flow from a compressor constructor.

Methods inherited from class java.lang.Object

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

Constructor Detail

CompressionUtils

public CompressionUtils()

Method Detail

compressorFlow

public static Flow<ByteString,ByteString,NotUsed> compressorFlow(scala.Function0<Compressor> newCompressor)

Creates a flow from a compressor constructor.

Parameters:

newCompressor - (undocumented)

Returns:

(undocumented)