Method PushSrc

downloader/diff_resolver.go:148–155

(v interface{})

}

func (dr *DiffResolver) PushSrc(v interface{}) {
	switch x := v.(type) {
	case *cluster.LOM:
		dr.srcCh <- x
	default:
		cos.Assertf(false, "%T", x)
	}
}

func (dr *DiffResolver) CloseSrc() { close(dr.srcCh) }