streams

type Compressor ¶

type Compressor interface {
	Compress(src []byte) (res []byte, err error)
	Decompress(src []byte) (res []byte, err error)
}

Compressor defines the interface for compression providers

type Huff0Compressor ¶

type Huff0Compressor struct {
	Compressor
	// contains filtered or unexported fields
}

Huff0Compressor is a Huffman encoding and decoding as used in "zstd". "Huff0, a Huffman codec designed for modern CPU, featuring OoO (Out of Order) operations on multiple ALU (Arithmetic Logic Unit), achieving extremely fast compression and decompression speeds." ```

compressor := streams.NewHuff0Compressor()
streamer := &miniaudio.Miniaudio{Format: malgo.FormatS16, Compressor: compressor}

``` With a modern processor this compressor delivers an average lossless compression between 20% to 30% on PCM data with a latency < 0.5 milliseconds for encoding + decoding.

func NewHuff0Compressor() *Huff0Compressor

func (c *Huff0Compressor) Compress(src []byte) (res []byte, err error)

func (c *Huff0Compressor) Decompress(src []byte) (res []byte, err error)

type Streamable ¶

type Streamable interface {

	// Configure is the designated configuration method
	Configure(address string, sampleRate float64, nbChannels int, echo bool, done chan interface{})

	// ReadStreamFrom reads the chunks from the stream.
	ReadStreamFrom(c io.Reader) error

	// WriteStreamTo writes to the given connection stream
	WriteStreamTo(c io.Writer) error

	// Address correspond to the <IP or Name:PORT>
	Address() string

	// SampleRate is the sample rate :)
	SampleRate() float64

	// NbChannels stereo = 2
	NbChannels() int

	// Echo if responding true prints the flow in the stdio
	Echo() bool

	// Done is the cancellation channel
	Done() chan interface{}
}

Streamable the interface to implement to be streamable over a network.