func (l *Launcher) run() {
	for {
		select {
		case source := <-l.tcpSources:
			listener := NewTCPListener(l.pipelineProvider, source, l.frameSize)
			listener.Start()
			l.listeners = append(l.listeners, listener)
		case source := <-l.udpSources:
			listener := NewUDPListener(l.pipelineProvider, source, l.frameSize)
			listener.Start()
			l.listeners = append(l.listeners, listener)
		case <-l.stop:
			return
		}
	}
}
// run starts new network listeners.
run starts new network listeners.
// run starts new network listeners .
func (l *Launcher) run() {
	for {
		select {
		case source := <-l.tcpSources:
			listener := NewTCPListener(l.pipelineProvider, source, l.frameSize)
			listener.Start()
			l.listeners = append(l.listeners, listener)
		case source := <-l.udpSources:
			listener := NewUDPListener(l.pipelineProvider, source, l.frameSize)
			listener.Start()
			l.listeners = append(l.listeners, listener)
		case <-l.stop:
			return
		}
	}
}
func ( l * Launcher ) run ( ) { for { select { case source := <- l . tcpSources : listener := NewTCPListener ( l . pipelineProvider , source , l . frameSize ) listener . Start ( ) l . listeners = append ( l . listeners , listener ) case source := <- l . udpSources : listener := NewUDPListener ( l . pipelineProvider , source , l . frameSize ) listener . Start ( ) l . listeners = append ( l . listeners , listener ) case <- l . stop : return } } }
run starts new network listeners.
run starts new network listeners .