code: func (s *auditService) Serve() {
  	defer close(s.stopped)
  	sub := events.Default.Subscribe(events.AllEvents)
  	defer events.Default.Unsubscribe(sub)
  	enc := json.NewEncoder(s.w)
  
  	// We're ready to start processing events.
  	close(s.started)
  
  	for {
  		select {
  		case ev := <-sub.C():
  			enc.Encode(ev)
  		case <-s.stop:
  			return
  		}
  	}
  }
docs: // Serve runs the audit service.