Versions in this module Expand all Collapse all v0 v0.1.1 Sep 6, 2026 v0.1.0 Aug 31, 2026 Changes in this version + var ErrEndOfStream = errors.New("end of stream") + type ItemFilter interface + Accept func(context.Context, T) (bool, error) + type ItemMapper interface + Map func(context.Context, T) (R, error) + type ItemReader interface + ReadFrom func(context.Context) (T, error) + type ItemWriter interface + Write func(context.Context, T) error + type MapperFunc func(context.Context, T) (R, error) + func (m MapperFunc[T, R]) Map(ctx context.Context, item T) (R, error) + type Pipeline struct + func From[T any](itemReader ItemReader[T]) *Pipeline[T] + func Just[T any](elems ...T) *Pipeline[T] + func (p *Pipeline[T]) Filter(itemFilter ItemFilter[T]) *Pipeline[T] + func (p *Pipeline[T]) FilterFunc(f func(context.Context, T) (bool, error)) *Pipeline[T] + func (p *Pipeline[T]) If(f func(item T) bool) *Pipeline[T] + func (p *Pipeline[T]) MapFunc[R any](f func(context.Context, T) (R, error)) *Pipeline[R] + func (p *Pipeline[T]) MapTo[R any](itemMapper ItemMapper[T, R]) *Pipeline[R] + func (p *Pipeline[T]) Tap(tapper Tapper[T]) *Pipeline[T] + func (p *Pipeline[T]) TapFunc(f func(context.Context, T) error) *Pipeline[T] + func (p *Pipeline[T]) WriteTo(ctx context.Context, itemWriter ItemWriter[T]) error + type Predicate func(context.Context, T) (bool, error) + func (p Predicate[T]) Accept(ctx context.Context, item T) (bool, error) + type TapFunc func(context.Context, T) error + func (t TapFunc[T]) Tap(ctx context.Context, item T) error + type Tapper interface + Tap func(context.Context, T) error
Go to main page