diff options
| author | John Christopher Anderson <jchris@apache.org> | 2009-09-14 20:20:50 +0000 |
|---|---|---|
| committer | John Christopher Anderson <jchris@apache.org> | 2009-09-14 20:20:50 +0000 |
| commit | 159ce7f416c430137b2b71f0ef6ffbb6a5c8f2ec (patch) | |
| tree | 963717120b2f360765b18a8507a4828e9c5e9c4a /src/couchdb/couch_rep_changes_feed.erl | |
| parent | 89fc389a328c54efbc03c4cbf56dc363db7e97f7 (diff) | |
finish committing my changes adventure. pardon the dust.
git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@814828 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'src/couchdb/couch_rep_changes_feed.erl')
| -rw-r--r-- | src/couchdb/couch_rep_changes_feed.erl | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/couchdb/couch_rep_changes_feed.erl b/src/couchdb/couch_rep_changes_feed.erl index f301b6e7..a89756e0 100644 --- a/src/couchdb/couch_rep_changes_feed.erl +++ b/src/couchdb/couch_rep_changes_feed.erl @@ -277,9 +277,13 @@ by_seq_loop(Server, Source, StartSeq) -> decode_row(<<",\n", Rest/binary>>) -> decode_row(Rest); decode_row(Row) -> - {[Seq, Id, {<<"changes">>,C}]} = ?JSON_DECODE(Row), + {Props} = ?JSON_DECODE(Row), + % [Seq, Id, {<<"changes">>,C}] + Seq = proplists:get_value(<<"seq">>, Props), + Id = proplists:get_value(<<"id">>, Props), + C = proplists:get_value(<<"changes">>, Props), C2 = [{[{<<"rev">>,couch_doc:parse_rev(R)}]} || {[{<<"rev">>,R}]} <- C], - {[Seq, Id, {<<"changes">>,C2}]}. + {[{<<"seq">>, Seq}, {<<"id">>,Id}, {<<"changes">>,C2}]}. flush_updated_messages() -> receive updated -> flush_updated_messages() |