pull_through

package

v1.1.0 Latest Latest Go to latest Published: Jan 14, 2020 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Event string

const (
	DataEvent Event = "data"
	EndEvent  Event = "end"
	ErrEvent  Event = "error"
)

type Option func(through *Through)

func WithEnder(ender func()) Option

func WithWriter(writer func(interface{})) Option

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

func NewThrough(opts ...Option) *Through

func (t *Through) Emit(event Event, data interface{})

func (t *Through) EnQueue(data interface{})

func (t *Through) Through() pull.Through