executable.go

package co

import (
	"log"
)

type executable[R any] struct {
	fn func() (R, error)
}

func NewExecutor[R any]() *executable[R] {
	return &executable[R]{}
}

func (e *executable[R]) exe() (R, error) {
	defer func() {
		if r := recover(); r != nil {
			log.Println("executable function error: %w", r)
		}
	}()
	return e.fn()
}

type executablesList[R any] struct {
	*iterativeList[*executable[R]]
}

func NewExecutablesList[R any]() *executablesList[R] {
	return &executablesList[R]{
		iterativeList: NewIterativeList[*executable[R]](),
	}
}

func (c *executablesList[R]) AddExecutable(fns ...func() (R, error)) *executablesList[R] {
	for i := range fns {
		e := NewExecutor[R]()
		e.fn = fns[i]
		c.add(e)
	}
	return c
}

func (it *executablesList[R]) iterator() executableListIterator[R] {
	return executableListIterator[R]{iterativeListIterator: it.iterativeList.iterator(), executablesList: it}
}

type executableListIterator[R any] struct {
	*executablesList[R]
	*iterativeListIterator[*executable[R]]
}

func (it *executableListIterator[R]) preflight() bool {
	defer func() { it.currentIndex++ }()
	return it.iterativeListIterator.preflight()
}

func (it *executableListIterator[R]) exeAt(i int) (R, error) {
	return it.executablesList.getAt(i).exe()
}