anchor.diff:      end.
   
   read_partial_body(State, _Vsn, Hdrs, chunked) ->
  -    read_partial_chunked_body(State, Hdrs, State#client_state.download_window,
  -        0, [], 0);
  +    Window = State#client_state.download_window,
  +    read_partial_chunked_body(State, Hdrs, Window, 0, [], 0);
   read_partial_body(State, Vsn, Hdrs, infinite) ->
       check_infinite_response(Vsn, Hdrs),
       read_partial_infinite_body(State, Hdrs, State#client_state.download_window);
  
positive.code:             erlang:error(Reason)
      end.
  
  
  send_chunked_body_part(_State, _Buffer, Window, 0) ->
      Window;
  send_chunked_body_part(State = #client_state{requester = Pid}, Buff, 0, Size) ->
      receive
          {ack, Pid} ->
              send_chunked_body_part(State, Buff, 1, Size);
          {'DOWN', _, process, Pid, _} ->
              exit(normal)
      end;
  send_chunked_body_part(#client_state{requester = Pid}, Buffer, Window, _Size) ->
      Pid ! {body_part, self(), list_to_binary(lists:reverse(Buffer))},
      receive
          {ack, Pid} ->  Window;
  
negative.code:             erlang:error({bad_trailer, Data})
      end.
  
  reply_end_of_body(#client_state{requester = Requester}, Trailers, Hdrs) ->
      Requester ! {http_eob, self(), Trailers},
      {no_return, Hdrs}.
  
  