anchor.diff:        handle_subscription2(SubscriberPid);
       Msg ->
         io:format("Unknown response ~p~n", [Msg])
  +      exit(unknown_response)
     after 5000 ->
  -    io:format("Timeout1~n"),
       exit(timeout)
     end.
   
   handle_subscription2(SubscriberPid) ->
     receive
       {gun_sse, Pid, Ref, Event} ->
  -      io:format("event ~p", [Event]),
  +      io:format("Event ~p", [Event]),
         handle_subscription2(SubscriberPid);
       {'DOWN', _MRef, process, _ConnPid, Reason} ->
         exit(Reason);
  
positive.code:   application:ensure_all_started(gun),
    {ok, {Scheme, _, HostBinary, Port, _, _}} = http_uri:parse(Url),
    Host = binary_to_list(HostBinary),
    {ok, ConnPid} = case Scheme of
      https -> gun:open(Host, Port, #{transport => ssl});
      http -> gun:open(Host, Port)
    end,
    {ok, Protocol} = gun:await_up(ConnPid),
    io:format("Connected to store at ~p://~s:~p~n", [Protocol, Host, Port]),
  
negative.code:       io:format("Msg ~p", [Msg]),
        handle_subscription2(SubscriberPid)
    after 5000 ->
      handle_subscription2(SubscriberPid)
    end.
  
  