@eryx/compression/stream Module

Summary

Functions

DecompressionReadStream:read(size: number?)string
DecompressionReadStream:readSync(size: number?)string
DecompressionReadStream:readBuffer(size: number?)buffer
DecompressionReadStream:readBufferSync(size: number?)buffer
DecompressionReadStream:close()()
DecompressionReadStream:closeSync()()
CompressionWriteStream:write(data: string | buffer)number
CompressionWriteStream:writeSync(data: string | buffer)number
CompressionWriteStream:flush()()
CompressionWriteStream:flushSync()()
CompressionWriteStream:close()()
CompressionWriteStream:closeSync()()
compressionStream.wrap(source: streamTypes.StreamThatCanRead, decompressor: Decompressor, options: WrapOptions?)ReadStream

API Reference

Functions

DecompressionReadStream:read

DecompressionReadStream:read(size: number?)string

DecompressionReadStream:readSync

DecompressionReadStream:readSync(size: number?)string

DecompressionReadStream:readBuffer

DecompressionReadStream:readBuffer(size: number?)buffer

DecompressionReadStream:readBufferSync

DecompressionReadStream:readBufferSync(size: number?)buffer

DecompressionReadStream:close

DecompressionReadStream:close()()

DecompressionReadStream:closeSync

DecompressionReadStream:closeSync()()

CompressionWriteStream:write

CompressionWriteStream:write(data: string | buffer)number

CompressionWriteStream:writeSync

CompressionWriteStream:writeSync(data: string | buffer)number

CompressionWriteStream:flush

CompressionWriteStream:flush()()

CompressionWriteStream:flushSync

CompressionWriteStream:flushSync()()

CompressionWriteStream:close

CompressionWriteStream:close()()

CompressionWriteStream:closeSync

CompressionWriteStream:closeSync()()

compressionStream.wrap

compressionStream.wrap(source: streamTypes.StreamThatCanRead, decompressor: Decompressor, options: WrapOptions?)ReadStream

compressionStream.wrapWriter

compressionStream.wrapWriter(sink: streamTypes.StreamThatCanWrite, compressor: Compressor, options: WrapWriterOptions?)WriteStream

Types

Decompressor

type Decompressor = { write: ((self: any, data: buffer) → (buffer, boolean)), close: ((self: any) → ()) }
Decompressor:write(data: buffer)(buffer, boolean)
Decompressor:close()()

Compressor

type Compressor = { write: ((self: any, data: buffer, flush: number?) → buffer), finish: ((self: any) → buffer), close: ((self: any) → ()), flush: (((self: any) → buffer))? }
Compressor:write(data: buffer, flush: number?)buffer
Compressor:finish()buffer
Compressor:close()()
flush: (((self: any) → buffer))?

WrapOptions

type WrapOptions = { chunkSize: number?, closeSource: boolean? }
chunkSize: number?
closeSource: boolean?

WrapWriterOptions

type WrapWriterOptions = { closeSink: boolean? }
closeSink: boolean?

ReadStream

type ReadStream = streamTypes.ReadOnlyStream
Implements: streamTypes.ReadOnlyStream

WriteStream

type WriteStream = streamTypes.WriteOnlyStream & streamTypes.StreamThatCanFlush
Implements: streamTypes.WriteOnlyStream, streamTypes.StreamThatCanFlush