anchor.diff:      % Artificially prolong message handling to avoid races between response from
       % the server and connection close.
       test_utils:mock_new(Workers, router),
  -    test_utils:mock_expect(Workers, router, preroute_message,
  -        fun(Msg, SessionId) ->
  +    test_utils:mock_expect(Workers, router, route_message,
  +        fun(Msg) ->
               timer:sleep(2000),
  -            meck:passthrough([Msg, SessionId])
  +            meck:passthrough([Msg])
           end
       ),
   
  
positive.code:     {ok, {Sock, SessionId}} = spawn_ssl_echo_client(Worker1),
  
      % when
      {ok, MsgId} = rpc:call(Worker1, communicator, communicate_async,
          [ServerMsgInternal, SessionId, Self]),
  
      % then
      ?assertReceivedMatch(#client_message{
  
negative.code:     % when
      {ok, {Sock, SessionId}} = spawn_ssl_echo_client(Worker1),
      CommunicateResult = rpc:call(Worker1, communicator, communicate,
          [ServerMsgInternal, SessionId, #{wait_for_ans => true}]),
  
      % then
      ?assertMatch({ok, #client_message{message_body = Status}}, CommunicateResult),
  