code: @Override
      public void onSuccess(Channel channel, final RiakMessage response)
      {
          logger.debug("Operation onSuccess() channel: id:{} {}:{}", channel.hashCode(), remoteAddress, port);
          consecutiveFailedOperations.set(0);
          final FutureOperation inProgress = inProgressMap.get(channel);
  
          // Especially with a streaming op, the close listener may trigger causing
          // a race. This check guards that.
          if (inProgress != null)
          {
              inProgress.setResponse(response);
  
              if (inProgress.isDone())
              {
                  try
                  {
                      inProgressMap.remove(channel);
                      returnConnection(channel); // return permit
                  }
                  finally
                  {
                      inProgress.setComplete();
                  }
              }
          }
      }
docs: End ConnectionPool stuff