anchor.diff:  		end,
   
   	Req1 =
  -		try handle_read_stream(Hmod, Bucket, Key, Params, S2pid, Ref, Timeout, Req0)
  +		try handle_read_stream(Hmod, Bucket, Key, Params, S2pid, Ref, ReadTimeout, Req0)
   		catch T:R ->
   			?ERROR_REPORT(datastore_http_log:format_request(Req0), T, R),
   			cowboy_req:reply(422, Req0)
  
positive.code: 	{ok, Req1, State}.
  
  handle_update(Req0, #state{rdesc = Rdesc, key = Key, bucket = Bucket, params = Params, s2reqopts = S2reqopts} =State) ->
  	#{object := #{pool := S2pool, options := S2opts},
  		object_aclobject := #{pool := KVpool, bucket := AclObjBucket}} = Rdesc,
  
  	%% Uploading object
  	S2pid = gunc_pool:lock(S2pool),
  	Ref = riaks2c_object:put(S2pid, Bucket, Key, <<>>, S2reqopts, S2opts),
  	Req1 = upstream_body(S2pid, Ref, Req0),
  	MaybeOk = riaks2c_object:await_put(S2pid, Ref),
  	gunc_pool:unlock(S2pool, S2pid),
  
  	Req2 =
  
negative.code: handle_write(#{method := <<"DELETE">>} =Req, State) -> handle_delete(Req, State).
  
  handle_delete(Req0, #state{rdesc = Rdesc, key = Key, bucket = Bucket, params = Params, s2reqopts = S2reqopts} =State) ->
  	#{object := #{pool := S2pool, options := S2opts, read_timeout := ReadTimeout},
  		object_aclobject := #{pool := KVpool, bucket := AclObjBucket}} = Rdesc,
  
  	%% Removing object
  	S2pid = gunc_pool:lock(S2pool),
  	MaybeOk = riaks2c_object:await_remove(S2pid, riaks2c_object:remove(S2pid, Bucket, Key, S2reqopts, S2opts), ReadTimeout),
  	gunc_pool:unlock(S2pool, S2pid),
  
  	Req1 =
  