async

package

v0.0.2-rc1 Latest Latest Go to latest Published: Dec 13, 2019 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Task represents a task

func NewTask(fn TaskFunc, data ...interface{}) *Task

NewTask creates a new task

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

Data returns the tasks data

func (t *Task) Run()

Run runs the task

func (t *Task) Stop() error

Stop stops the task

func (t *Task) Wait() error

Wait waits the task to be stopped

type TaskFunc func(ctx context.Context) error

TaskFunc is the task's func