code: func (l *logStream) Close() error {
  	l.lock.Lock()
  	defer l.lock.Unlock()
  	if !l.closed {
  		close(l.messages)
  	}
  	l.closed = true
  	return nil
  }
docs: // Close closes the instance of the awslogs logging driver