io

May 10, 2021

Changes in this version

type CompressedInputStream

+ func NewCompressedInputStreamWithCtx2(ibs kanzi.InputBitStream, ctx map[string]interface{}) (*CompressedInputStream, error)

type CompressedOutputStream

+ func NewCompressedOutputStreamWithCtx2(obs kanzi.OutputBitStream, ctx map[string]interface{}) (*CompressedOutputStream, error)

Nov 11, 2019

Changes in this version

+ type CompressedInputStream struct

+ func NewCompressedInputStream(is io.ReadCloser, jobs uint) (*CompressedInputStream, error)

+ func NewCompressedInputStreamWithCtx(is io.ReadCloser, ctx map[string]interface{}) (*CompressedInputStream, error)

+ func (this *CompressedInputStream) AddListener(bl kanzi.Listener) bool

+ func (this *CompressedInputStream) Close() error

+ func (this *CompressedInputStream) GetRead() uint64

+ func (this *CompressedInputStream) Read(block []byte) (int, error)

+ func (this *CompressedInputStream) RemoveListener(bl kanzi.Listener) bool

+ type CompressedOutputStream struct

+ func NewCompressedOutputStream(os io.WriteCloser, codec, transform string, blockSize, jobs uint, ...) (*CompressedOutputStream, error)

+ func NewCompressedOutputStreamWithCtx(os io.WriteCloser, ctx map[string]interface{}) (*CompressedOutputStream, error)

+ func (this *CompressedOutputStream) AddListener(bl kanzi.Listener) bool

+ func (this *CompressedOutputStream) Close() error

+ func (this *CompressedOutputStream) GetWritten() uint64

+ func (this *CompressedOutputStream) RemoveListener(bl kanzi.Listener) bool

+ func (this *CompressedOutputStream) Write(block []byte) (int, error)

+ type IOError struct

+ func NewIOError(msg string, code int) *IOError

+ func (this IOError) Error() string

+ func (this IOError) ErrorCode() int

+ func (this IOError) Message() string

+ type NullOutputStream struct

+ func NewNullOutputStream() (*NullOutputStream, error)

+ func (this *NullOutputStream) Close() error

+ func (this *NullOutputStream) Write(b []byte) (n int, err error)