anchor.diff:  
   peek_stanzas(Client) ->
       {messages, Msgs} = process_info(self(), messages),
  -    Transport = get_transport_for(Client),
  +    Transport = transport_matching_hack(Client),
       lists:flatmap(fun ({stanza, T, Stanza}) when T == Transport ->
                             [Stanza];
                         %% FIXME: stream error
  
positive.code:     {resource, R} = lists:keyfind(resource, 1, Proplist),
      <<U/binary,"@",S/binary,"/",R/binary>>.
  
  get_transport_for(Client) ->
      Client#client{jid = undefined}.
negative.code:     lists:reverse(Acc);
  do_wait_for_stanzas(#client{event_client=EventClient} = Client,
                      Count, TimeoutMsg, Acc) ->
      Transport = transport_matching_hack(Client),
      receive
          {stanza, Transport, Stanza} ->
              escalus_event:pop_incoming_stanza(EventClient, Stanza),
  