INNER CODE UNIT · Go

x

lucagrulla/cw · coordinator.go:32

			x := f.targets.Value.(chan<- time.Time)
			x <- time.Now()
			f.targets = f.targets.Next()
			f.Unlock()
		}
	}()
}

func (f *tailCoordinator) remove(c chan<- time.Time) {
	f.RLock()
	initialLen := f.targets.Len()
	f.RUnlock()

	var visited int
	f.Lock()
	defer f.Unlock()

	if f.targets.Len() == 1 {

View source record →