code: public synchronized final void setResponse(RiakMessage rawResponse)
      {
          stateCheck(State.CREATED, State.WRITTEN, State.RETRY);
          U decodedMessage = decode(rawResponse);
  
          processMessage(decodedMessage);
  
          exception = null;
          if (done(decodedMessage))
          {
              logger.debug("Setting to Cleanup Wait State");
              remainingTries--;
              if (retrier != null)
              {
                  retrier.operationComplete(this, remainingTries);
              }
              state = State.CLEANUP_WAIT;
          }
      }
docs: Exposed for testing.