future

Documentation

Index

• type Ctx
• type Value
  • func Go(fn func(ctx1 Ctx) (interface{}, error)) Value
  • func Pipe(val Value, fn func(data interface{}) (interface{}, error)) Value

Types

type Ctx

type Ctx interface {
	Cancel()

	WithCancel(parent context.Context) context.Context
	WithDeadline(parent context.Context, d time.Time) context.Context
	WithTimeout(parent context.Context, timeout time.Duration) context.Context
	// contains filtered or unexported methods
}

type Value

type Value interface {
	Err() error
	Error() string
	Get() interface{}
	Cancel()
	Wait(func(data interface{}) error) error
	// contains filtered or unexported methods
}

func Go

func Go(fn func(ctx1 Ctx) (interface{}, error)) Value

func Pipe

func Pipe(val Value, fn func(data interface{}) (interface{}, error)) Value