fanout

Documentation

Index

• type Consumer
• type ConsumerFunc
  • func (f ConsumerFunc) Read(p []byte) error
• type ReadAllConsumer
• type ReadAllConsumerFunc
  • func (f ReadAllConsumerFunc) ReadAll(r io.Reader) (interface{}, error)
• type ReadAllReader
  • func NewReadAllReader(reader io.Reader, consumers ...ReadAllConsumer) *ReadAllReader
  • func (r *ReadAllReader) GetReader(i int) io.Reader
  • func (r *ReadAllReader) ReadAll() ([]interface{}, error)
• type Reader
  • func NewReader(reader io.Reader, consumers ...Consumer) *Reader
  • func (r *Reader) Read(p []byte) (int, error)

Types

type Consumer

type Consumer interface {
	Read([]byte) error
}

type ConsumerFunc

type ConsumerFunc func([]byte) error

func (ConsumerFunc) Read

func (f ConsumerFunc) Read(p []byte) error

type ReadAllConsumer

type ReadAllConsumer interface {
	ReadAll(io.Reader) (interface{}, error)
}

type ReadAllConsumerFunc

type ReadAllConsumerFunc func(io.Reader) (interface{}, error)

func (ReadAllConsumerFunc) ReadAll

func (f ReadAllConsumerFunc) ReadAll(r io.Reader) (interface{}, error)

type ReadAllReader

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

A reader that emits its read to multiple consumers using a ReadAll(p []byte) ([]interface{}, error) func

func NewReadAllReader

func NewReadAllReader(reader io.Reader, consumers ...ReadAllConsumer) *ReadAllReader

func (*ReadAllReader) GetReader

func (r *ReadAllReader) GetReader(i int) io.Reader

func (*ReadAllReader) ReadAll

func (r *ReadAllReader) ReadAll() ([]interface{}, error)

type Reader

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

A reader that emits its read to multiple consumers using an io.Reader Read(p []byte) (int, error) func

func NewReader

func NewReader(reader io.Reader, consumers ...Consumer) *Reader

func (*Reader) Read

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