untypedchain

package

v0.0.0-...-a89a7b4 Latest Latest Go to latest Published: Nov 21, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func WithConfig(ctx context.Context, cfg any) context.Context

type Aggregator = internal.Aggregator

type Chain = internal.Chain

func Aggregated(f Aggregator, name ...string) Chain

func Conditional(cond Condition, f Chain, name ...string) Chain

func Exploded(f Exploder, name ...string) Chain

func Filtered(f Filter, name ...string) Chain

func Mapped(f Mapper, name ...string) Chain

func New() Chain

func Parallel(f Chain, p processing.Processing, name ...string) Chain

func Sorted(f CompareFunc, name ...string) Chain

func Stable(f Chain, p processing.Processing, name ...string) Chain

type CompareFunc = internal.CompareFunc

type Condition = internal.Condition

type Executor[T any] struct {
	// contains filtered or unexported fields
}

func For[T any](seq iter.Seq[T]) *Executor[T]

For can be used to execute an untyped chain for a typed iterator (`For(it).Execute(chain))

func (e *Executor[T]) Execute(ctx context.Context, c Chain) iter.Seq[any]

func (e *Executor[T]) ExecuteWithConfig(ctx context.Context, cfg any, c Chain) iter.Seq[any]

type Exploder = internal.Exploder

type Filter = internal.Filter

type Mapper = internal.Mapper

type Processor[R any] func(context.Context, iter.Seq[any]) R

type ProcessorFactory[R any] func() Processor[R]

type Sink[R any] interface {
	Execute(context.Context, iter.Seq[any]) R
}

func NewSink[R any](c Chain, p ProcessorFactory[R]) Sink[R]