func (l *TCPListener) startTailer(conn net.Conn) {
	l.mu.Lock()
	defer l.mu.Unlock()
	tailer := NewTailer(l.source, conn, l.pipelineProvider.NextPipelineChan(), l.read)
	l.tailers = append(l.tailers, tailer)
	tailer.Start()
}
// startTailer creates and starts a new tailer that reads from the connection.
startTailer creates and starts a new tailer that reads from the connection.
// startTailer creates and starts a new tailer that reads from the connection .
func (l *TCPListener) startTailer(conn net.Conn) {
	l.mu.Lock()
	defer l.mu.Unlock()
	tailer := NewTailer(l.source, conn, l.pipelineProvider.NextPipelineChan(), l.read)
	l.tailers = append(l.tailers, tailer)
	tailer.Start()
}
func ( l * TCPListener ) startTailer ( conn net . Conn ) { l . mu . Lock ( ) defer l . mu . Unlock ( ) tailer := NewTailer ( l . source , conn , l . pipelineProvider . NextPipelineChan ( ) , l . read ) l . tailers = append ( l . tailers , tailer ) tailer . Start ( ) }
startTailer creates and starts a new tailer that reads from the connection.
startTailer creates and starts a new tailer that reads from the connection .