anchor.diff:  	terminate(State, {connection_error, timeout,
   		'Connection idle longer than configuration allows.'}).
   
  -%% Request-line.
   parse(<<>>, State) ->
  +	before_loop(State, <<>>);
  +%% Do not process requests that come in after the last request
  +%% and discard the buffer if any to save memory.
  +parse(_, State=#state{in_streamid=InStreamID, in_state=#ps_request_line{},
  +		last_streamid=LastStreamID}) when InStreamID > LastStreamID ->
   	before_loop(State, <<>>);
   parse(Buffer, State=#state{in_state=#ps_request_line{empty_lines=EmptyLines}}) ->
   	after_parse(parse_request(Buffer, State, EmptyLines));
  
positive.code: 	loop(State, Buffer).
  
  loop(State=#state{parent=Parent, socket=Socket, transport=Transport, opts=Opts,
  		timer=TimerRef, children=Children, streams=Streams}, Buffer) ->
  	{OK, Closed, Error} = Transport:messages(),
  	InactivityTimeout = maps:get(inactivity_timeout, Opts, 300000),
  	receive
  		%% Socket messages.
  		{OK, Socket, Data} ->
  			%% Only reset the timeout if it is idle_timeout (active streams).
  
negative.code: 	%% We may want to get bodies that are below a threshold without waiting, and buffer them
  	%% until the request asks, though.
  	after_parse(parse_body(Buffer, State)).
  
  after_parse({request, Req=#{streamid := StreamID, method := Method,
  		headers := Headers, version := Version},
  