future

Documentation

Index

• type Future
  • func All[T any](ctx context.Context, futures ...Future[T]) Future[[]T]
  • func Error[T any](err error) Future[T]
  • func First[T any](ctx context.Context, first, second Future[T]) Future[T]
  • func Last[T any](ctx context.Context, first, second Future[T]) Future[T]
  • func Result[T any](result T, err error) Future[T]
  • func Task[T any](ctx context.Context, task func(ctx context.Context) (T, error)) Future[T]
  • func Value[T any](value T) Future[T]

Types

type Future

type Future[T any] interface {
	Get(ctx context.Context) (T, error)
	Done() <-chan struct{}
	IsDone() bool
}

func All

func All[T any](ctx context.Context, futures ...Future[T]) Future[[]T]

func Error

func Error[T any](err error) Future[T]

func First

func First[T any](ctx context.Context, first, second Future[T]) Future[T]

func Last

func Last[T any](ctx context.Context, first, second Future[T]) Future[T]

func Result

func Result[T any](result T, err error) Future[T]

func Task

func Task[T any](ctx context.Context, task func(ctx context.Context) (T, error)) Future[T]

func Value

func Value[T any](value T) Future[T]