tasks

Documentation

Index

• Variables
• type CompletionSource
  • func NewCompletionSource() *CompletionSource
  • func (s *CompletionSource) SetError(err error) error
  • func (s *CompletionSource) SetResult(result interface{}) error
  • func (s *CompletionSource) Task() *Task
  • func (s *CompletionSource) TrySetError(err error) bool
  • func (s *CompletionSource) TrySetResult(result interface{}) bool
• type ContinueWithCallback
• type Task
  • func New(cb TaskCallback) *Task
  • func NewStarted(cb TaskCallback) *Task
  • func (t *Task) ContinueWith(cb ContinueWithCallback) *Task
  • func (t *Task) Error() error
  • func (t *Task) IsCompleted() bool
  • func (t *Task) IsFaulted() bool
  • func (t *Task) Result() interface{}
  • func (t *Task) Start() error
  • func (t *Task) Wait() error
• type TaskCallback

Variables

var AlreadyCompleted = errors.New("Already completed")

var AlreadyRunning = errors.New("Already running")

Types

type CompletionSource

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

func NewCompletionSource

func NewCompletionSource() *CompletionSource

func (*CompletionSource) SetError

func (s *CompletionSource) SetError(err error) error

func (*CompletionSource) SetResult

func (s *CompletionSource) SetResult(result interface{}) error

func (*CompletionSource) Task

func (s *CompletionSource) Task() *Task

func (*CompletionSource) TrySetError

func (s *CompletionSource) TrySetError(err error) bool

func (*CompletionSource) TrySetResult

func (s *CompletionSource) TrySetResult(result interface{}) bool

type ContinueWithCallback

type ContinueWithCallback func(*Task) (interface{}, error)

type Task

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

func New

func New(cb TaskCallback) *Task

func NewStarted

func NewStarted(cb TaskCallback) *Task

func (*Task) ContinueWith

func (t *Task) ContinueWith(cb ContinueWithCallback) *Task

func (*Task) Error

func (t *Task) Error() error

func (*Task) IsCompleted

func (t *Task) IsCompleted() bool

func (*Task) IsFaulted

func (t *Task) IsFaulted() bool

func (*Task) Result

func (t *Task) Result() interface{}

func (*Task) Start

func (t *Task) Start() error

func (*Task) Wait

func (t *Task) Wait() error

type TaskCallback

type TaskCallback func() (interface{}, error)