Searched refs:MergePathInfoStreams (Results 1 – 3 of 3) sorted by relevance
93 return MergePathInfoStreams(ctx, piCs), MergeErrStreams(ctx, errCs)
27 func MergePathInfoStreams(ctx context.Context, piCs []<-chan *res.PathInfo) <-chan *res.PathInfo { func
37 mergedC := MergePathInfoStreams(ctx, []<-chan *res.PathInfo{in1, in2})