chunker

package

v0.5.0 Latest Latest Go to latest Published: Dec 7, 2018 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Package chunker provides functionalities to create chunks from an io.Reader and also create an io.Reader from chunks.

This section is empty.

This section is empty.

This section is empty.

type Chunker struct {
	// contains filtered or unexported fields
}

Chunker converts data read from reader into chunks.

func New(r io.Reader, chunks chan Data, err chan error, options ...Option) *Chunker

New returns a new chunker for r and it forwards each chunk to chunks channel. an error will be sent to err channel if chunking fails.

func (c *Chunker) Close() error

Close will stop reading from reader and no more chunks will be emitted.

type Data struct {
	// Value carries the context value of data chunk.
	Value interface{}

	// Data is data chunk.
	Data []byte
}

Data represents a data chunk.

type Option func(*Chunker)

Option is the configuration func of Chunker.

func ChunkSizeOption(n int) Option

ChunkSizeOption returns an option to set chunk size.

func ValueOption(value interface{}) Option

ValueOption returns an option to set context value to chunks.

type Stream struct {
	// contains filtered or unexported fields
}

Stream implements io.Reader.

func NewStream() *Stream

NewStream returns a new stream.

func (s *Stream) Close() error

Close closes reader.

func (s *Stream) Provide(data []byte)

Provide provides data for Read.

func (s *Stream) Read(p []byte) (n int, err error)

Read puts data into p.