future

Documentation

Index

• Variables
• type Future
  • func FutureFunc[T any](implem interface{}, args ...interface{}) *Future[T]
  • func (f *Future[T]) Get() (T, error)
  • func (f *Future[T]) GetWithTimeout(timeout time.Duration) (T, error)

Variables

var (
	// ErrTimeOut timed out
	ErrTimeOut = errors.New("timed out")
)

Types

type Future

type Future[T any] struct {
	Success          bool
	Done             bool
	Result           T
	InterfaceChannel <-chan T
	// contains filtered or unexported fields
}

Future type holds Result and state

func FutureFunc

func FutureFunc[T any](implem interface{}, args ...interface{}) *Future[T]

FutureFunc creates a function that returns its response in future

func (*Future[T]) Get

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

Get return the result when available. This is a blocking call

func (*Future[T]) GetWithTimeout

func (f *Future[T]) GetWithTimeout(timeout time.Duration) (T, error)

GetWithTimeout return the result until timeout.