Documentation
¶
Index ¶
- func APipe(val abc.FutureValue, fn interface{}) (val1 abc.FutureValue)
- func Async(fn interface{}, args ...interface{}) (val1 abc.FutureValue)
- func Await(val abc.FutureValue, fn interface{}, errs ...func(err error))
- func Promise(provider rxgo.Producer, opts ...rxgo.Option) rxgo.Observable
- func RunComplete(values ...abc.FutureValue) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func APipe ¶ added in v0.3.18
func APipe(val abc.FutureValue, fn interface{}) (val1 abc.FutureValue)
func Async ¶
func Async(fn interface{}, args ...interface{}) (val1 abc.FutureValue)
func Await ¶
func Await(val abc.FutureValue, fn interface{}, errs ...func(err error))
func RunComplete ¶
func RunComplete(values ...abc.FutureValue) (err error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.