errors

package main

import (
	"context"
	"fmt"
	"strconv"

	"github.com/agiac/rivo"
	"github.com/agiac/rivo/errors"
)

func main() {
	ctx := context.Background()

	g := rivo.Of("1", "2", "3_", "4", "5**")

	toInt := rivo.Map(func(ctx context.Context, i rivo.Item[string]) (int, error) {
		return strconv.Atoi(i.Val)
	})

	logValue := rivo.Do[int](func(ctx context.Context, i rivo.Item[int]) {
		fmt.Printf("Value: %d\n", i.Val)
	})

	errs := make([]error, 0)
	errorHandler := rivo.Do[struct{}](func(ctx context.Context, i rivo.Item[struct{}]) {
		errs = append(errs, i.Err)
	})

	<-rivo.Pipe3(g, errors.WithErrorHandler(toInt, errorHandler), logValue)(ctx, nil)

	for _, err := range errs {
		fmt.Printf("Error: %v\n", err)
	}

}

Output:

Value: 1
Value: 2
Value: 4
Error: strconv.Atoi: parsing "3_": invalid syntax
Error: strconv.Atoi: parsing "5**": invalid syntax