async

Documentation

Index

• type Runner
  • func NewRunner(f ...func(stop <-chan struct{})) *Runner
  • func (r *Runner) Add(fn func(stop <-chan struct{}))
  • func (r *Runner) Start()
  • func (r *Runner) Stop()

Types

type Runner

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

func NewRunner

func NewRunner(f ...func(stop <-chan struct{})) *Runner

NewRunner makes a runner for the given function(s). The function(s) should loop until the channel is closed.

func (*Runner) Add

func (r *Runner) Add(fn func(stop <-chan struct{}))

func (*Runner) Start

func (r *Runner) Start()

Start begins running.

func (*Runner) Stop

func (r *Runner) Stop()

Stop stops running.