code: func WithCloseOutChan() func(*Queue) error {
  	return func(q *Queue) error {
  		q.closeOutChan = true
  		return nil
  	}
  }
docs: // WithCloseOutChan returns a functional option for a queue whose watcher
  // channel is closed when no more events are expected to be sent to the watcher.