util

type RunnerWithContext interface {
	// Run blocks in processing until context sends a stop signal
	// because it has been interrupted externally. It can be cancelled
	// also by this function to broadcast stop to other parallel
	// routines.
	// Run should change accordingly the implementation running state
	// so that IsRunning can be used to query for it.
	Run(ctx context.Context, cancel context.CancelFunc) error
	// IsRunning returns the running state of this RunnerWithContext
	IsRunning() bool
}