ll

Documentation

Index

• type EndRunFn
• type Ender
  • func End[I any](runFn EndRunFn[I]) Ender[I]
• type MultiError
  • func (m *MultiError) Error() string
• type PipeRunFn
• type Piper
  • func Pipe[I, O any](runFn PipeRunFn[I, O]) Piper[I, O]
• type Sink
• type Starter
  • func Start[I, O any](runFn PipeRunFn[I, O]) Starter[I, O]
• type Term

Types

type EndRunFn

type EndRunFn[I any] func(I, Term)

type Ender

type Ender[I any] interface {
	Sink[I]
	Wait() error
}

func End

func End[I any](runFn EndRunFn[I]) Ender[I]

type MultiError

type MultiError struct {
	Errors []error
}

func (*MultiError) Error

func (m *MultiError) Error() string

type PipeRunFn

type PipeRunFn[I, O any] func(I, Sink[O])

type Piper

type Piper[I, O any] interface {
	Sink[I]
	Next(Sink[O])
}

func Pipe

func Pipe[I, O any](runFn PipeRunFn[I, O]) Piper[I, O]

type Sink

type Sink[T any] interface {
	Write(T)
	Term
}

type Starter

type Starter[I, O any] interface {
	Piper[I, O]
	Start() Starter[I, O]
}

func Start

func Start[I, O any](runFn PipeRunFn[I, O]) Starter[I, O]

type Term

type Term interface {
	Error(error)
	Done()
	// contains filtered or unexported methods
}