futures

package

v0.0.0-...-11ada09 Latest Latest Go to latest Published: Feb 23, 2020 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var ErrFutureCanceled = errors.New("future canceled")

This section is empty.

type Completer <-chan interface{}

type Future struct {
	// contains filtered or unexported fields
}

func New(completer Completer, timeout time.Duration) *Future

func (f *Future) GetResult() (interface{}, error)

GetResult will immediately fetch the result if it exists or wait on the result until it is ready.

func (f *Future) HasResult() bool

HasResult will return true iff the result exists

type Selectable struct {
	// contains filtered or unexported fields
}

func NewSelectable() *Selectable

func (f *Selectable) Cancel()

Cancel is alias for SetError(ErrFutureCanceled)

func (f *Selectable) Fill(v interface{}, e error) error

Fill sets value for future, if it were not already fullfilled Returns error, if it were already set to future.

func (f *Selectable) GetResult() (interface{}, error)

GetResult waits for future to be fullfilled and returns value or error, whatever is set first

func (f *Selectable) SetError(e error)

func (f *Selectable) SetValue(v interface{}) error

func (f *Selectable) WaitChan() <-chan struct{}

WaitChan returns channel, which is closed when future is fullfilled.