async

Documentation

Index

• type Outcome
  • func NewCompositeOutcome(outcomes ...Outcome) Outcome
  • func NewErrorOutcome(err error) Outcome
  • func NewOutcome() Outcome
  • func NewValueOutcome(value interface{}) Outcome
  • func (o Outcome) IsAvailable() bool
  • func (o Outcome) OnError(callback func(err error)) Outcome
  • func (o Outcome) OnSuccess(callback func(value interface{})) Outcome
  • func (o Outcome) Record(result Result)
  • func (o Outcome) Wait() Result
• type Result
• type Task
  • func VoidTask(callback func() error) Task
• type Worker
  • func NewWorker(capacity int) *Worker
  • func (w *Worker) ProcessAll()
  • func (w *Worker) ProcessTryMultiple(count int) bool
  • func (w *Worker) ProcessTrySingle() bool
  • func (w *Worker) Schedule(task Task) Outcome
  • func (w *Worker) Shutdown()
  • func (w *Worker) Wait(task Task) Result

Types

type Outcome

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

func NewCompositeOutcome

func NewCompositeOutcome(outcomes ...Outcome) Outcome

func NewErrorOutcome

func NewErrorOutcome(err error) Outcome

func NewOutcome

func NewOutcome() Outcome

func NewValueOutcome

func NewValueOutcome(value interface{}) Outcome

func (Outcome) IsAvailable

func (o Outcome) IsAvailable() bool

func (Outcome) OnError

func (o Outcome) OnError(callback func(err error)) Outcome

func (Outcome) OnSuccess

func (o Outcome) OnSuccess(callback func(value interface{})) Outcome

func (Outcome) Record

func (o Outcome) Record(result Result)

func (Outcome) Wait

func (o Outcome) Wait() Result

type Result

type Result struct {
	Value interface{}
	Err   error
}

type Task

type Task func() Result

func VoidTask

func VoidTask(callback func() error) Task

type Worker

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

func NewWorker

func NewWorker(capacity int) *Worker

func (*Worker) ProcessAll

func (w *Worker) ProcessAll()

func (*Worker) ProcessTryMultiple

func (w *Worker) ProcessTryMultiple(count int) bool

func (*Worker) ProcessTrySingle

func (w *Worker) ProcessTrySingle() bool

func (*Worker) Schedule

func (w *Worker) Schedule(task Task) Outcome

func (*Worker) Shutdown

func (w *Worker) Shutdown()

func (*Worker) Wait

func (w *Worker) Wait(task Task) Result