async

package

v0.1.10 Latest Latest Go to latest Published: Oct 9, 2024 License: MIT Imports: 2 Imported by: 0

Details

Package async provides a simple way to run functions asynchronously.

This section is empty.

This section is empty.

func Await[T any](f *Future[T]) (T, error)

Await waits for the future to resolve and returns the value.

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

Future is a type that represents a future value.

func All[T any](futures ...*Future[T]) *Future[[]T]

All returns a future that resolves when all the provided futures resolve.

func New[T any](fn func() (T, error)) *Future[T]

New returns a new future.

func (f *Future[T]) Await() (T, error)

Await waits for the future to resolve and returns the value.

func (f *Future[T]) Catch(fn func(error)) *Future[T]

Catch sets a callback to be called when the future rejects.

func (f *Future[T]) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (f *Future[T]) Then(fn func(T)) *Future[T]

Then sets a callback to be called when the future resolves.

func (f *Future[T]) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.