anchor.diff:      {stop, changes_loop_died, State};
   
   handle_info(Msg, State) ->
  -    ?LOG_INFO("unexpected message ~p", [Msg]),
  +    ?LOG_DEBUG("unexpected message at changes_feed ~p", [Msg]),
       {noreply, State}.
   
   terminate(_Reason, #state{conn=Pid}) when is_pid(Pid) ->
  
positive.code:         ParsedRevs = couch_doc:parse_revs(lists:flatten(RawRevs)),
          Change = {[
              {<<"seq">>, Seq},
              {<<"Id">>, Id},
              {<<"changes">>, [{[{<<"rev">>,R}]} || R <- ParsedRevs]}
          ]},
          gen_server:call(Server, {add_change, Change}),
          Seq
      end, 0, proplists:get_value(<<"rows">>, Results)),
      by_seq_loop(Server, Source, EndSeq+1).
  
  decode_row(<<",\n", Rest/binary>>) ->
  
negative.code:     last_seq,
      conn = nil,
      reqid = nil,
      complete = false,
      count = 0,
      partial_chunk = nil,
  