Method isStopped

sqlchain/observer/worker.go:160–171

()

}

func (w *subscribeWorker) isStopped() bool {
	if w.stopCh == nil {
		return true
	}

	select {
	case <-w.stopCh:
		return true
	default:
		return false
	}
}