anchor.diff:  %% after delay.
   %% @end
   %%--------------------------------------------------------------------
  --spec ensure_sent(Msg ::term(), SessId :: session:id()) -> ok.
  +-spec ensure_sent(Msg :: term(), SessId :: session:id()) -> ok.
   ensure_sent(Msg, SessId) ->
       case communicator:send(Msg, SessId) of
           ok ->
  
positive.code:     ?debug("Initializing sequencer manager for session ~p", [SessId]),
      process_flag(trap_exit, true),
      {ok, SessId} = session:update(SessId, #{sequencer_manager => self()}),
      send_message_stream_reset(SessId),
      {ok, #state{sequencer_manager_sup = SeqManSup, session_id = SessId}, 0}.
  
  %%--------------------------------------------------------------------
  
negative.code: send_message_stream_reset(SessId) ->
      ensure_sent(#message_stream_reset{}, SessId).
  
  %%--------------------------------------------------------------------
  %% @private
  %% @doc
  