anchor.diff:                  exml_stream:parse(Parser, Decompressed)
           end,
       NewState = State#state{parser = NewParser},
  -    Filter = State#state.filter,
       lists:foreach(fun(Stanza) ->
           escalus_event:incoming_stanza(EventClient, Stanza),
  -        case Filter(Stanza) of
  -            true ->
  -                Owner ! {stanza, transport(NewState), Stanza};
  -            false ->
  -                ok
  -        end
  +        Owner ! {stanza, transport(NewState), Stanza}
       end, Stanzas),
       case [StrEnd || #xmlstreamend{} = StrEnd <- Stanzas] of
           [] -> {noreply, NewState};
  
positive.code:     {ok, NewParser} = exml_stream:reset_parser(Parser),
      {reply, Socket, State#state{parser = NewParser,
                                  compress = {zlib, {Zin,Zout}}}};
  handle_call({set_filter, Filter}, _From, #state{} = S) ->
      {reply, ok, S#state{filter = Filter}};
  handle_call(stop, _From, #state{socket = Socket, ssl = Ssl,
                                  compress = Compress} = State) ->
      StreamEnd = escalus_stanza:stream_end(),
  
negative.code: 
  get_transport(#transport{rcv_pid = Pid}) ->
      gen_server:call(Pid, get_transport).
  
  %%%===================================================================
  %%% gen_server callbacks
  