code: func WithTimeout(timeout time.Duration) func(*Queue) error {
  	return func(q *Queue) error {
  		q.sinkGen = NewTimeoutDropErrSinkGen(timeout)
  		return nil
  	}
  }
docs: // WithTimeout returns a functional option for a queue that sets a write timeout