anchor.diff:  			end
   	end.
   
  +%% Children.
  +
  +new_child(State=#state{children=Children}, StreamID, Pid, IsFin) ->
  +	IsFin2 = if IsFin -> fin; true -> nofin end,
  +	State#state{last_streamid=StreamID,
  +		children=[#child{streamid=StreamID,
  +		pid=Pid, input=IsFin2}|Children]}.
  +
  +delete_child(Pid, State=#state{children=Children}) ->
  +	Children2 = lists:keydelete(Pid, #child.pid, Children),
  +	State#state{children=Children2}.
  +
  +get_child(StreamID, #state{children=Children}) ->
  +	lists:keyfind(StreamID, #child.streamid, Children).
  +
  +out_fin_child(Child=#child{streamid=StreamID},
  +		State=#state{children=Children}) ->
  +	Children2 = lists:keyreplace(StreamID,
  +		#child.streamid, Children, Child#child{output=fin}),
  +	State#state{children=Children2}.
  +
   %% Request process.
   
   request_init(FakeSocket, Peer, OnRequest, OnResponse,
  
positive.code: 		{recv, FromSocket = {Pid, StreamID}, FromPid, Length, _Timeout}
  				when Pid =:= self() ->
  			Child = #child{in_buffer=InBuffer, is_recv=false}
  				= lists:keyfind(StreamID, #child.streamid, Children),
  			if
  				Length =:= 0, InBuffer =/= <<>> ->
  					FromPid ! {recv, FromSocket, {ok, InBuffer}},
  
negative.code: %% Erlang does not allow us to control the priority of processes
  %% so we ignore that value entirely.
  handle_frame(State=#state{middlewares=Middlewares, env=Env,
  		onrequest=OnRequest, onresponse=OnResponse, peer=Peer},
  		{syn_stream, StreamID, _, IsFin, _, _,
  		Method, _, Host, Path, Version, Headers}) ->
  	Pid = spawn_link(?MODULE, request_init, [
  		{self(), StreamID}, Peer, OnRequest, OnResponse,
  		Env, Middlewares, Method, Host, Path, Version, Headers
  	]),
  	loop(new_child(State, StreamID, Pid, IsFin));
  %% RST_STREAM.
  handle_frame(State, {rst_stream, StreamID, Status}) ->
  	error_logger:error_msg("Received RST_STREAM frame ~p ~p",
  