reader

Documentation

Index

• Variables
• type MultiReader
  • func (r *MultiReader) Close() error
  • func (r *MultiReader) Read(ctx context.Context) (model.MXPGVKEvent, error)

Variables

var ErrEOF = event.ErrEOF

Types

type MultiReader

type MultiReader struct {
	Readers []event.Reader
}

MultiReader is the logical concatenation of its readers. They're read sequentially. Once all readers have returned EOF, Read will return EOF. If any of the readers return a non-nil, non-EOF error, Read will return that error. Readers are closed when they return EOF or when Close() is called.

func (*MultiReader) Close

func (r *MultiReader) Close() error

func (*MultiReader) Read

func (r *MultiReader) Read(ctx context.Context) (model.MXPGVKEvent, error)