anchor.diff:              State;
           {value, Req, L2} ->
               {reply, Reply, NewState} = on_timeout(Req, State),
  -            send_caller(Reply, Req),
  +            _ = send_caller(Reply, Req),
               NewState#state{queue = queue:from_list(L2)}
       end.
   
  
positive.code: %% @private
  send_request(Request, State) when State#state.active =:= undefined ->
      Pkt = riakc_pb:encode(Request#request.msg),
      gen_tcp:send(State#state.sock, Pkt),
      maybe_reply(after_send(Request, State#state{active = Request})).
  
  %% Queue up a request if one is pending
  
negative.code: 
  process_response(#request{msg = #rpbmapredreq{content_type = ContentType}}=Request,
                   #rpbmapredresp{done = Done, phase=PhaseId, response=Data}, State) ->
      _ = case Data of
              undefined ->
                  ok;
              _ ->
                  Response = decode_mapred_resp(Data, ContentType),
                  send_caller({mapred, PhaseId, Response}, Request)
          end,
      case Done of
          true ->
              {reply, done, State};
  