anchor.diff:      {reply, {ok, Keepalive, NewKeepalive},
        State#state{keepalive = NewKeepalive}};
   
  +handle_call(mark_as_terminated, _From, #state{} = State) ->
  +    {reply, {ok, marked_as_terminated}, State#state{terminated=true}};
  +
   handle_call(get_active, _From, #state{active = Active} = State) ->
       {reply, Active, State};
   handle_call({set_active, Active}, _From, State) ->
  
positive.code:     NS = handle_data(XmlBody, S#state{requests = NewRequests}),
      NNS = case {detect_type(Attrs), NS#state.keepalive, NS#state.requests == []}
            of
                {streamend, _, _} -> NS;
                {_, false, _}     -> NS;
                {_, true, true}   -> send(Transport, 
                                          empty_body(NS#state.rid, NS#state.sid),
  
negative.code: set_keepalive(#transport{rcv_pid = Pid}, NewKeepalive) ->
      gen_server:call(Pid, {set_keepalive, NewKeepalive}).
  
  mark_as_terminated(#transport{rcv_pid = Pid}) ->
      gen_server:call(Pid, mark_as_terminated).
  
  pause(#transport{rcv_pid = Pid} = Transport, Seconds) ->
      gen_server:cast(Pid, {pause, Transport, Seconds}).
  
  