INNER CODE UNIT · Go

targetChan

lucagrulla/cw · coordinator.go:58

			targetChan := f.targets.Value.(chan<- time.Time)

			f.targets = f.targets.Prev()
			f.targets.Unlink(1)
			close(targetChan)
			f.log.Printf("coordinator: channel found and removed at index: %d\n", visited)

			break
		}
		f.targets = f.targets.Next()
	}

	if f.targets.Len() < initialLen {
		for i := 0; i < visited; i++ {
			f.targets = f.targets.Prev()
		}
	}
}

View source record →