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

Field Summary

Fields

Modifier and Type	Field and Description
static CompressionUtils$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
CompressionUtils$()

Method Summary

Modifier and Type	Method and Description
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

Field Detail

MODULE$

public static final CompressionUtils$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

CompressionUtils$

public CompressionUtils$()

Method Detail

compressorFlow

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

Creates a flow from a compressor constructor.

Parameters:

newCompressor - (undocumented)

Returns:

(undocumented)