stream

package
v0.1.0-alpha.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 28, 2018 License: MPL-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewChunker

func NewChunker(source Source, setters ...Option) chunker.Chunker

NewChunker initializes a Chunker with default values.

Types

type Option

type Option func(*Options)

Option is the functional option func.

func Size

func Size(s int) Option

Size sets the chunk size of the Chunker.

type Options

type Options struct {
	Size int
}

Options is the functional options struct.

type Source

type Source interface {
	io.ReadCloser
}

Source is an interface describing the source of a Stream.

type Stream

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

Stream is a conecrete type that implements the chunker.Chunker interface.

func (*Stream) Read

func (c *Stream) Read(ctx context.Context) <-chan []byte

Read implements ChunkReader.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL