anchor.diff:      {noreply, send_request(Req, undefined, From, State)};
   handle_call({req, Req, Ctx}, From, State) ->
       {noreply, send_request(Req, Ctx, From, State)}.
  - 
  +
   %% @private
   handle_info({tcp_closed, _Socket}, State) ->
       {stop, normal, State};
  
positive.code: get_server_info(Pid) ->
      gen_server:call(Pid, {req, rpbgetserverinforeq}).
  
  %% @doc Get bucket/key from the server 
  %%      Will return {error, notfound} if the key is not on the server
  -spec get(pid(), bucket() | string(), key() | string()) -> {ok, riakc_obj()} | {error, term()}.
  get(Pid, Bucket, Key) ->
  
negative.code:         Code ->
              {error, {Code, ErrMsg#rpberrorresp.errmsg}}
      end.
  
  %% deliberately crash if the handling an error response after
  %% the client has been replied to
  
  