reader

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 (r *MultiReader) Close() error

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