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:       handle_subscription2(SubscriberPid);
      Msg ->
        io:format("Unknown response ~p~n", [Msg])
        exit(unknown_response)
    after 5000 ->
      exit(timeout)
    end.
  
  handle_subscription2(SubscriberPid) ->
    receive
      {gun_sse, Pid, Ref, Event} ->
        io:format("Event ~p", [Event]),
        handle_subscription2(SubscriberPid);
      {'DOWN', _MRef, process, _ConnPid, Reason} ->
        exit(Reason);
  