anchor.diff:           use_zlib/2,
            get_transport/1,
            reset_parser/1,
  -         stop/1]).
  +         stop/1,
  +         set_filter/2]).
   
   %% gen_server callbacks
   -export([init/1,
  
positive.code:                 exml_stream:parse(Parser, Decompressed)
          end,
      NewState = State#state{parser = NewParser},
      lists:foreach(fun(Stanza) ->
          escalus_event:incoming_stanza(EventClient, Stanza),
          Owner ! {stanza, transport(NewState), Stanza}
      end, Stanzas),
      case [StrEnd || #xmlstreamend{} = StrEnd <- Stanzas] of
          [] -> {noreply, NewState};
  
negative.code: 
  get_transport(#transport{rcv_pid = Pid}) ->
      gen_server:call(Pid, get_transport).
  
  set_filter(#transport{rcv_pid = Pid}, Filter) ->
      gen_server:call(Pid, {set_filter, Filter}).
  
  %%%===================================================================
  %%% gen_server callbacks
  