anchor.diff:  
   %% HELPER STREAMING EXPORTS
   -export([
  -    stream_fun/1,
  +    %stream_fun/1,
       stream_body/1
   ]).
   
  
positive.code:         RequestCache = #request_cache{request = Req} = cowboy_request_server:get(ReqKey),
          {RequestCache, Req}
      catch E:T ->
          error_logger:info_msg("~p:~p~n~p", [E, T, erlang:get_stacktrace()])
      end.
  
  put_key(ReqKey, NewRequestCache) ->
  
negative.code: 
  protocol(ReqKey) ->
      {_RequestCache, Req} = get_key(ReqKey),
      %Transport = cowboy_req:get(transport, Req),
      case cowboy_req:scheme(Req) of
          <<"http">> -> http;
          <<"https">> -> https
      end.
  
  
  request_method(ReqKey) ->
      {_RequestCache, Req} = get_key(ReqKey),
      Method = cowboy_req:method(Req),
      list_to_atom(simple_bridge_util:to_list(Method)).
  
  path(ReqKey) ->
      {_RequestCache, Req} = get_key(ReqKey),
      Path = cowboy_req:path(Req),
      simple_bridge_util:to_list(Path).
  
  uri(ReqKey) ->
      {_RequestCache, Req} = get_key(ReqKey),
      URL = cowboy_req:uri(Req),
      case re:run(URL, "^https?://[^/]*(/.*)$", [{capture, all_but_first, list}]) of
  	{match, [Uri]} -> Uri;
  	_ -> ""
      end.
  
  peer_ip(ReqKey) ->
      {RequestCache, Req} = get_key(ReqKey),
      {IP, _Port} = cowboy_req:peer(Req),
      put_key(ReqKey, RequestCache#request_cache{request = Req}),
      IP.
  
  peer_port(ReqKey) ->
      {RequestCache, Req} = get_key(ReqKey),
      {_IP, Port} = cowboy_req:peer(Req),
      put_key(ReqKey, RequestCache#request_cache{request = Req}),
      Port.
  
  headers(ReqKey) ->
      {_RequestCache, Req} = get_key(ReqKey),
      cowboy_req:headers(Req).
  
  
  cookies(ReqKey) ->
      {RequestCache, Req} = get_key(ReqKey),
      Cookies = cowboy_req:parse_cookies(Req),
      put_key(ReqKey, RequestCache#request_cache{request = Req}),
      Cookies.
  
  query_params(ReqKey) ->
      {RequestCache, Req} = get_key(ReqKey),
      QsVals = cowboy_req:parse_qs(Req),
      put_key(ReqKey, RequestCache#request_cache{request = Req}),
      QsVals.
  
  post_params(ReqKey) ->
      Body = request_body(ReqKey),
      cow_qs:parse_qs(Body).
  
  request_body(ReqKey) ->
      {RequestCache, Req} = get_key(ReqKey),
  