Function newWaitItem

kayak/waiter.go:44–51

(r *Runtime, index uint64)

}

func newWaitItem(r *Runtime, index uint64) *waitItem {
	return &waitItem{
		r:      r,
		index:  index,
		waitCh: make(chan struct{}, 1),
		stopCh: make(chan struct{}),
	}
}

func (i *waitItem) startFetch() {
	i.l.Lock()