anchor.diff:          streams = Stms,
           subscriptions = Subs
       }};
  -
  -handle_info({retry_request, 0, Request}, State) ->
  -    ?debug("Max retries for request: ~p", [Request]),
  -    {noreply, State};
   
   handle_info({retry_request, RetryCounter, Request}, State) ->
       gen_server2:cast(self(), {internal, RetryCounter - 1, Request}),
  
positive.code:         {ok, Stm} = event_stream_sup:start_stream(StmsSup, self(), Sub, SessId),
          {maps:put(StmKey, Stm, Stms), maps:put(Id, {local, StmKey}, Subs)}
      end, {#{}, #{}}, Docs).
  
negative.code: 
  -behaviour(gen_server).
  
  -include("global_definitions.hrl").
  -include("modules/events/definitions.hrl").
  -include("proto/oneclient/client_messages.hrl").
  -include("proto/common/handshake_messages.hrl").
  