lvstream

Documentation

Index

• Variables
• type LVStreamDecoder
  • func NewLVStreamDecoder(nextValue func([]byte) error) *LVStreamDecoder
  • func (decoder *LVStreamDecoder) Close() error
  • func (decoder *LVStreamDecoder) Write(p []byte) (int, error)
• type LVStreamEncoder
  • func NewLVStreamEncoder(nextValue func() ([]byte, error), cleanup func()) *LVStreamEncoder
  • func (encoder *LVStreamEncoder) Close() error
  • func (encoder *LVStreamEncoder) Read(p []byte) (int, error)

Variables

var EClosed = errors.New("Closed")

msg,msg,msg -> [length|msg|length|msg...] [length|msg|length|msg...] -> msg,msg,msg

var MaxValueSize = 10 * 1024 * 1024 * 1024

10 MB

Types

type LVStreamDecoder

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

func NewLVStreamDecoder

func NewLVStreamDecoder(nextValue func([]byte) error) *LVStreamDecoder

func (*LVStreamDecoder) Close

func (decoder *LVStreamDecoder) Close() error

func (*LVStreamDecoder) Write

func (decoder *LVStreamDecoder) Write(p []byte) (int, error)

type LVStreamEncoder

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

func NewLVStreamEncoder

func NewLVStreamEncoder(nextValue func() ([]byte, error), cleanup func()) *LVStreamEncoder

func (*LVStreamEncoder) Close

func (encoder *LVStreamEncoder) Close() error

func (*LVStreamEncoder) Read

func (encoder *LVStreamEncoder) Read(p []byte) (int, error)

Read implements io.Reader It will panic if any of the preconditions are not met.