anchor.diff:  
   %%
   %% peer connection
  -'STREAM'({Prot, _, {established, Peer}}, _Pipe, #fsm{queue = Queue0} = State)
  - when ?is_transport(Prot) ->
  -   Queue1 = q:map(fun(Req) -> Req#req{treq = os:timestamp()} end, Queue0),
  -   {next_state, 'STREAM', State#fsm{peer = Peer, queue = Queue1}};
  +'STREAM'({Prot, _, {established, Peer}}, _Pipe, #fsm{} = State)
  + when ?is_transport(Prot) ->   
  +   [$. ||
  +      lens:apply(lens:tuple(#fsm.queue), fun queue_config_treq/1, State),
  +      lens:put(lens_socket_peername(), Peer, _),
  +      fmap({next_state, 'STREAM', _})
  +   ];
   
   'STREAM'({Prot, _, {terminated, _}}, Pipe, #fsm{} = State)
    when ?is_transport(Prot) ->
  
positive.code:    } = deq:head(Q),
     ?access_http(#{
        req  => {Mthd, Code}
       ,peer => Peer
       ,addr => request_url(Url, HeadA)
       ,ua   => opts:val('User-Agent', opts:val('Server', undefined, HeadB), HeadA)
       ,time => tempus:diff(T)
     }),
     Http;
  
  http_request_log(#http{is = upgrade, http = {_, {_, Url, Head}}, state = #fsm{peer = Peer}} = Http) ->
     Upgrade = lens:get(lens:pair('Upgrade'), Head),
     ?access_http(#{
        req  => {upgrade, Upgrade}
       ,peer => Peer
       ,addr => request_url(Url, Head)
       ,ua   => opts:val('User-Agent', undefined, Head)
     }),
  
negative.code:    end.
  
  
  %%
  %% 
  queue_config_treq(Queue) ->
     q:map(fun(Req) -> Req#req{treq = os:timestamp()} end, Queue).
  
  %%%------------------------------------------------------------------
  %%%
  