anchor.diff:  
   -behaviour(gen_server).
   
  +-include("global_definitions.hrl").
   -include("modules/events/definitions.hrl").
   -include("proto/oneclient/client_messages.hrl").
   -include("proto/common/handshake_messages.hrl").
  
positive.code:     catch
          exit:{noproc, _} ->
              ?debug("No proc to handle request ~p, retry", [Request]),
              erlang:send_after(1000, self(), {retry_request, RetryCounter, Request}),
              {noreply, State};
          exit:{normal, _} ->
              ?debug("Exit of stream process for request ~p, retry", [Request]),
              erlang:send_after(1000, self(), {retry_request, RetryCounter, Request}),
              {noreply, State};
          exit:{timeout, _} ->
              ?debug("Exit of stream process for request ~p, retry", [Request]),
              erlang:send_after(1000, self(), {retry_request, RetryCounter, Request}),
              {noreply, State};
          Reason1:Reason2 ->
              ?error_stacktrace("Cannot process request ~p due to: ~p", [Request, {Reason1, Reason2}]),
              {noreply, State}
      end;
  handle_cast(Request, State) ->
      handle_cast({internal, 10, Request}, State).
  
  %%--------------------------------------------------------------------
  %% @private
  
negative.code:         streams = Stms,
          subscriptions = Subs
      }};
  
  handle_info({retry_request, RetryCounter, Request}, State) ->
      gen_server2:cast(self(), {internal, RetryCounter - 1, Request}),
  