promise

Documentation

Index

• func Wait(ws ...Waiter) error
• func WaitForAll[T any](promises []*Promise[T]) (err error)
• type Func
  • func WithCancellation[T, V any](f Func[T, V]) Func[T, V]
• type Func2
• type MapFunc
• type Promise
  • func MapAndThen[T, V, K any](ctx context.Context, p *Promise[T], mf MapFunc[T, K], f Func[K, V]) *Promise[V]
  • func NewPromise[T, V any](ctx context.Context, t T, f Func[T, V]) *Promise[V]
  • func Then[T, V any](ctx context.Context, p *Promise[T], f Func[T, V]) *Promise[V]
  • func Zip[T, K, V any](ctx context.Context, pt *Promise[T], pk *Promise[K], f Func2[T, K, V]) *Promise[V]
  • func (p *Promise[V]) Get() (V, error)
  • func (p *Promise[V]) Wait() error
• type Waiter

Functions

func Wait

func Wait(ws ...Waiter) error

func WaitForAll

func WaitForAll[T any](promises []*Promise[T]) (err error)

Types

type Func

type Func[T, V any] func(context.Context, T) (V, error)

func WithCancellation

func WithCancellation[T, V any](f Func[T, V]) Func[T, V]

type Func2

type Func2[T, K, V any] func(context.Context, T, K) (V, error)

type MapFunc

type MapFunc[T, V any] func(T) V

type Promise

type Promise[V any] struct {
	// contains filtered or unexported fields
}

func MapAndThen

func MapAndThen[T, V, K any](ctx context.Context, p *Promise[T], mf MapFunc[T, K], f Func[K, V]) *Promise[V]

func NewPromise

func NewPromise[T, V any](ctx context.Context, t T, f Func[T, V]) *Promise[V]

func Then

func Then[T, V any](ctx context.Context, p *Promise[T], f Func[T, V]) *Promise[V]

func Zip

func Zip[T, K, V any](ctx context.Context, pt *Promise[T], pk *Promise[K], f Func2[T, K, V]) *Promise[V]

func (*Promise[V]) Get

func (p *Promise[V]) Get() (V, error)

func (*Promise[V]) Wait

func (p *Promise[V]) Wait() error

type Waiter

type Waiter interface {
	Wait() error
}