anchor.diff:  send_end_of_body(#client_state{requester = Requester}, Trailers, Hdrs) ->
       Requester ! {http_eob, self(), Trailers},
       {no_return, Hdrs}.
  -    
  +
   read_partial_infinite_body(State = #client_state{requester = To}, Hdrs, 0) ->
       receive
           {ack, To} -> read_partial_infinite_body(State, Hdrs, 1);
  
positive.code:         {error, {http_error, Data}} ->
              erlang:error({bad_trailer, Data})
      end.
      
  read_trailers(Socket, Ssl, Hdrs) ->
      lhttpc_sock:setopts(Socket, [{packet, httph}], Ssl),
      case lhttpc_sock:recv(Socket, Ssl) of
  
negative.code: 
  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; 
          {'DOWN', _, process, Pid, _} -> exit(normal)
      after 0 ->
          lhttpc_lib:dec(Window)
      end.
  
  read_chunked_body(Socket, Ssl, Hdrs, Chunks) ->
      case read_chunk_size(Socket, Ssl) of
  