Add async/await

async/async.go

@@ -0,0 +1,39 @@
+package async
+
+import "context"
+
+// Future mimics the async/await paradigm
+type Future[T any] interface {
+	Await() (T, error)
+}
+
+type future[T any] struct {
+	await func(ctx context.Context) (T, error)
+}
+
+func (f future[T]) Await() (T, error) {
+	return f.await(context.Background())
+}
+
+func Exec[T any](f func() (T, error)) Future[T] {
+	var (
+		result T
+		err    error
+	)
+	c := make(chan struct{})
+	go func() {
+		defer close(c)
+
+		result, err = f()
+	}()
+	return future[T]{
+		await: func(ctx context.Context) (T, error) {
+			select {
+			case <-ctx.Done():
+				return result, ctx.Err()
+			case <-c:
+				return result, err
+			}
+		},
+	}
+}

async/async_test.go

@@ -0,0 +1,24 @@
+package async
+
+import (
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestAsync(t *testing.T) {
+	// Async
+	do := Exec(func() (bool, error) {
+		time.Sleep(2 * time.Second)
+		return true, nil
+	})
+
+	// do some other stuff
+	time.Sleep(time.Second)
+
+	// Await
+	ok, err := do.Await()
+	require.Nil(t, err)
+	require.True(t, ok)
+}