code: func (l *Logs) Start() <-chan *Event {
  	ch := make(chan *Event)
  	done := make(chan error)
  
  	for _, name := range l.GroupNames {
  		go l.consume(name, ch, done)
  	}
  
  	go func() {
  		l.wait(done)
  		close(ch)
  	}()
  
  	return ch
  }
docs: // Start consuming logs.