async

package

v0.0.14 Latest Latest Go to latest Published: Mar 21, 2025 License: GPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func Gather[T any](promises ...Future[T]) Future[[]Future[T]]

func Run[T any](f func() T) Future[T]

func Wait[T any](promises ...Future[T]) Future[<-chan Future[T]]

func (future Future[T]) Channel() <-chan T

func (future Future[T]) ErrorChannel() <-chan error

func (future Future[T]) MustValue() monad.Result[T]

func (future Future[T]) Status() Status

func (future Future[T]) String() string

func (future Future[T]) Value() T

func (future Future[T]) Wait()

type FutureNotFinishedError struct {
	// contains filtered or unexported fields
}

func NewFutureNotFinishedError() FutureNotFinishedError

type FutureNotStartedError struct {
	// contains filtered or unexported fields
}

func NewFutureNotStartedError() FutureNotStartedError

type Status int

const (
	StatusNotStarted Status = iota
	StatusWorking
	StatusFinished
	StatusError
)

func (status Status) String() string