anchor.diff:      % when
       {ok, {Sock, SessionId}} = spawn_ssl_echo_client(Worker1),
       CommunicateResult = rpc:call(Worker1, communicator, communicate,
  -        [ServerMsgInternal, SessionId]),
  +        [ServerMsgInternal, SessionId, #{wait_for_ans => true}]),
   
       % then
       ?assertMatch({ok, #client_message{message_body = Status}}, CommunicateResult),
  
positive.code: protobuf_msg_test(Config) ->
      % given
      [Worker1 | _] = Workers = ?config(op_worker_nodes, Config),
      test_utils:mock_expect(Workers, router, preroute_message, fun
          (#client_message{message_body = #events{events = [#event{
              type = #file_read_event{}
          }]}}, _) -> ok
      end),
      Msg = #'ClientMessage'{
          message_id = <<"0">>,
  
negative.code:     end),
  
      % when
      {ok, MsgId2} = rpc:call(Worker1, communicator, communicate,
          [ServerMsgInternal, SessionId, #{use_msg_id => true}]),
  
      % then
      ?assertReceivedMatch({router_message_called, MsgId2}, ?TIMEOUT),
  