stoppable_task

Documentation

Index

• type StoppableTask
  • func Run(f func(stop <-chan struct{})) *StoppableTask
  • func (task *StoppableTask) Stop(timeout time.Duration)

Types

type StoppableTask

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

func Run

func Run(f func(stop <-chan struct{})) *StoppableTask

func (*StoppableTask) Stop

func (task *StoppableTask) Stop(timeout time.Duration)