anchor.diff:        io:format("Msg ~p", [Msg]),
         handle_subscription2(SubscriberPid)
     after 5000 ->
  -    io:format("Timeout2~n"),
       handle_subscription2(SubscriberPid)
     end.
   
  
positive.code:   end.
  
  subscribe(Store, Project, SubscriberPid) ->
    ok.
    % io:format("Subscribing ~p", [SubscriberPid]),
    % Path = to_path(Project, subscribe),
    % Headers = [{<<"accept">>, <<"text/event-stream">>}] ++ headers(Store),
    % ConnPid = maps:get(connection, Store),
    % HandlerPid = spawn(?MODULE, handle_subscription, [SubscriberPid]),
    % gun:get(ConnPid,
    %         Path,
    %         Headers,
    %         #{reply_to => HandlerPid}).
  
  handle_subscription(SubscriberPid) ->
    receive
  
negative.code:   application:ensure_all_started(gun),
    {ok, {Scheme, _, HostBinary, Port, _, _}} = http_uri:parse(Url),
    Host = binary_to_list(HostBinary),
    HttpOpts = #{
      content_handlers => [gun_sse, gun_data],
      keepalive => infinity
    },
    Opts = #{
      trace => false,
      http_opts => HttpOpts,
      http2_opts => HttpOpts
    },
    {ok, ConnPid} = case Scheme of
      https -> gun:open(Host, Port, maps:set(transport, ssl, Opts));
      http -> gun:open(Host, Port, Opts)
    end,
    {ok, Protocol} = gun:await_up(ConnPid),
    io:format("Connected to store at ~p://~s:~p~n", [Protocol, Host, Port]),
  