anchor.diff:  
   %%
   %%
  -up_link_decode(Msg, #fsm{recv = Recv0, peer = Peer} = State) ->
  -   {Pckt, Recv1} = htstream:decode(Msg, Recv0),
  -   #http{
  -      is    = htstream:state(Recv1),
  -      http  = htstream:http(Recv1),
  -      pack  = up_link_message(Pckt, Peer),
  -      state = State#fsm{recv = Recv1} 
  -   }.
  +up_link_decode(Data, #fsm{socket = Socket0, peer = Peer} = State) ->
  +   {Pckt, #socket{in = Stream} = Socket1} = gen_http_recv(Socket0, Data),
  +   http_set_state(Stream, Socket1, #http{pack = up_link_message(Pckt, Peer), state = State}).
  +
   
   up_link_message({Mthd, Url, Head}, Peer) 
    when ?is_method(Mthd) ->
  
positive.code:    Queue1 = qmap(fun(Req) -> Req#req{treq = T} end, Queue0),
     {next_state, 'STREAM', State#fsm{peer = Peer, queue = Queue1}};
  
  'STREAM'({Prot, _, {terminated, _}}, _Pipe, #fsm{queue = Q} = State)
   when ?is_transport(Prot) ->
     %% @todo: clean-up state
     % case htstream:state(Stream#stream.recv) of
  
negative.code: %%
  %%
  down_link_return(Pipe, #http{is = eoh, state = State}) ->
     %% htstream has a feature of "eoh event". 
     down_link([], Pipe, State);
  
  down_link_return(_Pipe, #http{state = State}) ->
  