code: func (oc *OutputChannel) Close() {
  	if oc.stop == nil {
  		return
  	}
  	oc.stop <- struct{}{}
  	<-oc.stop
  	oc.stop = nil
  	oc.Flush()
  }
docs: // Close closes the output channel and release the consumer's go routine.