streamio

Documentation

Index

• func MD5Hash(in []byte) []byte
• type MsgReader
• type Reader
  • func NewReader(mr MsgReader) *Reader
  • func (r *Reader) Read(p []byte) (int, error)

Functions

func MD5Hash

func MD5Hash(in []byte) []byte

Types

type MsgReader

type MsgReader interface {
	// Returns the next message.
	// If no message available, return nil, nil
	Read() ([]byte, error)
}

MsgReader wraps a message-based Read function

type Reader

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

Reader implements a streaming io.Reader from a MessageReader

func NewReader

func NewReader(mr MsgReader) *Reader

NewReader creates a streaming reader from a MessageReader

func (*Reader) Read

func (r *Reader) Read(p []byte) (int, error)

Read implements the read function in io.Reader