anchor.diff:  %% Listens for events and pushes them to the socket
   %% @end
   %%--------------------------------------------------------------------
  --spec event_loop(function(), reference(), timeout(), req(), #{}) -> {ok, req()} | no_return().
  +-spec event_loop(function(), reference(), timeout(), req(), #{}) -> ok | no_return().
   event_loop(SendChunk, Id, Timeout, Req, State) ->
       receive
           {Id, [_ | _] = Events, _Ctx} ->
  
positive.code:             event_loop(SendChunk, Id, Timeout, Req, State)
      after
          Timeout ->
              {ok, Req}
      end.
  
  %%--------------------------------------------------------------------
  
negative.code:         event_loop(SendChunk, Id, Timeout, Req2, State)
      end,
      Req3 = cowboy_req:set_resp_body_fun(chunked, StreamFun, Req2),
      {ok, Req4} = cowboy_req:reply(?HTTP_OK, [], same(Req3)),
      {halt, Req4, State}.
  
  
  