Function fanIn

BaseServer/concurrentHashMap.go:239–252

fanIn reads elements from channels `chans` into channel `out`

(chans []chan Tuple, out chan Tuple)

// fanIn reads elements from channels `chans` into channel `out`
func fanIn(chans []chan Tuple, out chan Tuple) {
	wg := sync.WaitGroup{}
	wg.Add(len(chans))
	for _, ch := range chans {
		go func(ch chan Tuple) {
			for t := range ch {
				out <- t
			}
			wg.Done()
		}(ch)
	}
	wg.Wait()
	close(out)
}

// Returns all items as map[string]interface{}
func (m ConcurrentHashMap) Items() map[string]interface{} {