stream

Documentation

Index

• type InputStreamer
  • func (r *InputStreamer) Read() (output []byte, err error)
  • func (r *InputStreamer) ReadJSONObject() ([]byte, error)
  • func (r *InputStreamer) ReadLine() ([]byte, error)

Types

type InputStreamer

type InputStreamer struct {
	IgnoreEmptyLines bool
	Buffer           *bufio.Reader
}

InputStreamer an input streamer which breaks down a buffer into input values

func (*InputStreamer) Read

func (r *InputStreamer) Read() (output []byte, err error)

Read reads the next delimited value (either text or JSON object)

func (*InputStreamer) ReadJSONObject

func (r *InputStreamer) ReadJSONObject() ([]byte, error)

ReadJSONObject read the next JSON object

func (*InputStreamer) ReadLine

func (r *InputStreamer) ReadLine() ([]byte, error)

ReadLine reads the next chunk of text until the next newline char