package compression
- Source
- package.scala
- Alphabetic
- By Inheritance
- compression
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- class CompressionException extends RuntimeException
Signals that exception occurred in compression/decompression
- sealed abstract class CompressionLevel extends AnyRef
- final case class CompressionParameters(level: CompressionLevel, strategy: CompressionStrategy, flushMode: FlushMode) extends Product with Serializable
- sealed abstract class CompressionStrategy extends AnyRef
- sealed abstract class FlushMode extends AnyRef
Value Members
- def deflate(bufferSize: Int = 32 * 1024, compressionParameters: CompressionParameters = CompressionParameters.Default, noWrap: Boolean = false): (Observable[Array[Byte]]) => Observable[Array[Byte]]
Compresses stream with 'deflate' method described in https://tools.ietf.org/html/rfc1951.
Compresses stream with 'deflate' method described in https://tools.ietf.org/html/rfc1951.
- bufferSize
Size of internal buffer used for pulling data from deflater, affects performance.
- compressionParameters
- noWrap
Whether output stream is wrapped in ZLIB header and trailer. For HTTP 'deflate' content-encoding should be false, see https://tools.ietf.org/html/rfc2616.
- def gunzip(bufferSize: Int = 32 * 1024): (Observable[Array[Byte]]) => Observable[Array[Byte]]
Decompresses gzipped stream.
Decompresses gzipped stream. Compression method is described in https://tools.ietf.org/html/rfc1952.
- bufferSize
Size of buffer used internally, affects performance.
- def gzip(bufferSize: Int = 32 * 1024, compressionParameters: CompressionParameters = CompressionParameters.Default, fileName: Option[String] = None, comment: Option[String] = None, modificationTime: Option[Instant] = None): (Observable[Array[Byte]]) => Observable[Array[Byte]]
Returns a stream that incrementally compresses input into the GZIP format
Returns a stream that incrementally compresses input into the GZIP format
- bufferSize
Size of buffer used internally, affects performance.
- compressionParameters
- fileName
optional file name
- comment
optional file modification time
- modificationTime
optional file comment
- def inflate(bufferSize: Int = 32 * 1024, noWrap: Boolean = false): (Observable[Array[Byte]]) => Observable[Array[Byte]]
Decompresses deflated stream.
Decompresses deflated stream. Compression method is described in https://tools.ietf.org/html/rfc1951.
- bufferSize
Size of buffer used internally, affects performance.
- noWrap
Whether is wrapped in ZLIB header and trailer, see https://tools.ietf.org/html/rfc1951. For HTTP 'deflate' content-encoding should be false, see https://tools.ietf.org/html/rfc2616.
- object CompressionException extends Serializable
- object CompressionLevel
- object CompressionParameters extends Serializable
- object CompressionStrategy
- object FlushMode
This is the API documentation for the Monix library.
Package Overview
monix.execution exposes lower level primitives for dealing with asynchronous execution:
Atomictypes, as alternative tojava.util.concurrent.atomicmonix.catnap exposes pure abstractions built on top of the Cats-Effect type classes:
monix.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the
Observablepattern:Observableimplementationsmonix.tail exposes Iterant for purely functional pull based streaming:
BatchandBatchCursor, the alternatives to Scala'sIterableandIteratorrespectively that we are using within Iterant's encodingYou can control evaluation with type you choose - be it Task, Coeval, cats.effect.IO or your own as long as you provide correct cats-effect or cats typeclass instance.