code: func (rs *retryingSink) wait(backoff time.Duration) {
  	rs.mu.Unlock()
  	defer rs.mu.Lock()
  
  	// backoff here
  	time.Sleep(backoff)
  }
docs: // wait backoff time against the sink, unlocking so others can proceed. Should
  // only be called by methods that currently have the mutex.