anchor.diff:  handle_info({'EXIT', SeqManSup, shutdown}, #state{sequencer_manager_sup = SeqManSup} = State) ->
       {stop, normal, State};
   
  -handle_info(timeout, #state{sequencer_manager_sup = SeqManSup} = State) ->
  +handle_info(timeout, #state{sequencer_manager_sup = SeqManSup, session_id = SessId} = State) ->
  +    send_message_stream_reset(SessId),
       {ok, SeqInStmSup} = sequencer_manager_sup:get_sequencer_stream_sup(
           SeqManSup, sequencer_in_stream_sup
       ),
  
positive.code: send_message_stream_reset(SessId) ->
      ensure_sent(#message_stream_reset{}, SessId).
  
  
  %%--------------------------------------------------------------------
  %% @private
  %% @doc
  
negative.code: %% after delay.
  %% @end
  %%--------------------------------------------------------------------
  -spec ensure_sent(Msg :: term(), SessId :: session:id()) -> ok.
  ensure_sent(Msg, SessId) ->
      case communicator:send(Msg, SessId) of
          ok ->
  