anchor.diff:                      #'ServerMessage'{message_id = Id, message_body = Body} =
                           server_messages:decode_msg(Data, 'ServerMessage'),
   
  -                    % respond with the same data to the server
  -                    ClientAnsProtobuf = #'ClientMessage'{message_id = Id, message_body = Body},
  -                    ClientAnsRaw = client_messages:encode_msg(ClientAnsProtobuf),
  -                    ?assertEqual(ok, ssl:send(Sock, ClientAnsRaw)),
  +                    % respond with the same data to the server (excluding stream_reset)
  +                    case Body of
  +                        {message_stream_reset, _} -> ok;
  +                        _ ->
  +                            ClientAnsProtobuf = #'ClientMessage'{message_id = Id, message_body = Body},
  +                            ClientAnsRaw = client_messages:encode_msg(ClientAnsProtobuf),
  +                            ?assertEqual(ok, ssl:send(Sock, ClientAnsRaw))
  +                    end,
   
                       %loop back
                       Loop();
  
positive.code: -perf_test([
      {repeats, 3},
      {perf_configs, [
          {ssl_through_oneproxy, [{msg_num, 100000}, {transport, ssl}]},
          {tcp_direct, [{msg_num, 100000}, {transport, gen_tcp}]}
      ]},
      {ct_config, [{msg_num, 100}, {transport, ssl}]}
  ]).
  % open connection and send 'msg_num' pings, then receive 'msg_num' pongs
  multi_ping_pong_test(Config) ->
      % given
      remove_pending_messages(),
      [Worker1 | _] = ?config(op_worker_nodes, Config),
      Transport = ?config(transport, Config),
      MsgNum = ?config(msg_num, Config),
      MsgNumbers = lists:seq(1, MsgNum),
      MsgNumbersBin = lists:map(fun(N) -> integer_to_binary(N) end, MsgNumbers),
      Pings = lists:map(
  
negative.code:         multi_message_test, client_send_test, client_communicate_test,
          client_communiate_async_test, multi_ping_pong_test,
          sequential_ping_pong_test, multi_connection_test, bandwidth_test,
          python_client_test, proto_version_test].
  
  -define(TOKEN, <<"TOKEN_VALUE">>).
  
  