anchor.diff:  	NewMFA ->
   	    ?hdrd("data processed - reactivate socket", [{new_mfa, NewMFA}]),
   	    http_transport:setopts(SockType, Socket, [{active, once}]),
  -            {noreply, State#state{mfa = NewMFA}}
  +	    case NewDataSize of
  +		undefined ->
  +		    {noreply, State#state{mfa = NewMFA}};
  +		_ ->
  +		    {noreply, State#state{mfa = NewMFA, data = NewDataSize}}
  +	    end
       end;
   
   %% Error cases
  
positive.code:     ?hdrt("activate request timeout", [{time, Time}]),    
      Ref = erlang:send_after(Time, self(), timeout),
      State#state{timer = Ref}.
  
  cancel_request_timeout(#state{timer = undefined} = State) ->
      State;
  cancel_request_timeout(#state{timer = Timer} = State) ->
  
negative.code: 		timeout,  %% infinity | integer() > 0
  		timer,     %% ref() - Request timer
  		headers,  %% #http_request_h{}
  		body,      %% binary()
  		data,      %% The total data received in bits, checked after 10s
  		bit_limit  %% Bit limit per second before kick out
  	       }).
  
  %%====================================================================
  