main.go

package main

import (
	"context"
	"fmt"
	"mpragliola/pype/pkg/pipe"
	"time"
)

func main() {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	a := pipe.Of([]int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10})
	b := pipe.Filter(ctx, evenFilter, a)
	c, _ := pipe.Map(ctx, squareFilter, b)
	d, errCh := pipe.Map(ctx, hate64function, c)
	e, _ := pipe.Map(ctx, slowMap, d)

	okFn := func(i int) { fmt.Println("-> ", i) }
	errFn := func(err error) {
		fmt.Println("ERROR", err)
	}

	pipe.Consume(ctx, e, errCh, okFn, errFn)
}

// ---

func evenFilter(i int) bool {
	return i%2 == 0
}

func squareFilter(i int) (int, error) {
	return i * i, nil
}

func slowMap(i int) (int, error) {
	fmt.Println("slow map", i)

	// Simulate a slow operation
	time.Sleep(1 * time.Second)

	return i, nil
}

func hate64function(i int) (int, error) {
	if i == 1 {
		return 0, fmt.Errorf("i hate 64")
	}
	return i, nil
}