anchor.diff:      rpc:call(Worker1, communicator, send, [ServerMsgInternal, SessionId]),
   
       % then
  -    ReceivedMessage =
  -        receive
  -            {ssl, _, Data} ->
  -                server_messages:decode_msg(Data, 'ServerMessage')
  -        after timer:seconds(5) ->
  -            {error, timeout}
  -        end,
  -    ?assertEqual(ServerMessageProtobuf, ReceivedMessage),
  +    ?assertEqual(ServerMessageProtobuf, receive_server_message()),
       ok = ssl:close(Sock).
   
   client_communicate_test(Config) ->
  
positive.code: 
  unmock_identity(Workers) ->
      test_utils:mock_validate(Workers, identity),
      test_utils:mock_unload(Workers, identity).
negative.code:     lists:foldl(fun(E, N) ->
          % send ping & receive pong
          ok = ssl:send(Sock, E),
          Pong = receive_server_message(),
  
          % validate pong
          BinaryN = integer_to_binary(N),
  