/*
 * Copyright (c) 2024 The GoPlus Authors (goplus.org). All rights reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package async

import (
	"unsafe"
	_ "unsafe"

	"github.com/goplus/llgo/c/libuv"
)

type Void = [0]byte

type Future[T any] func(func(T))

type asyncBind[T any] struct {
	libuv.Async
	result T
	chain  func(T)
}

func asyncCb[T any](a *libuv.Async) {
	a.Close(nil)
	aa := (*asyncBind[T])(unsafe.Pointer(a))
	aa.chain(aa.result)
}

func Async[T any](fn func(func(T))) Future[T] {
	return func(chain func(T)) {
		loop := Exec().L
		// var result T
		// var a *libuv.Async
		// var cb libuv.AsyncCb
		// a, cb = cbind.BindF[libuv.Async, libuv.AsyncCb](func() {
		// 	a.Close(nil)
		// 	chain(result)
		// })
		// loop.Async(a, cb)

		aa := &asyncBind[T]{chain: chain}
		loop.Async(&aa.Async, asyncCb[T])
		fn(func(v T) {
			aa.result = v
			aa.Send()
		})
	}
}