couchdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kocol...@apache.org
Subject svn commit: r829920 - /couchdb/trunk/src/couchdb/couch_rep_changes_feed.erl
Date Mon, 26 Oct 2009 19:51:32 GMT
Author: kocolosk
Date: Mon Oct 26 19:51:32 2009
New Revision: 829920

URL: http://svn.apache.org/viewvc?rev=829920&view=rev
Log:
_changes response might have completed already

Modified:
    couchdb/trunk/src/couchdb/couch_rep_changes_feed.erl

Modified: couchdb/trunk/src/couchdb/couch_rep_changes_feed.erl
URL: http://svn.apache.org/viewvc/couchdb/trunk/src/couchdb/couch_rep_changes_feed.erl?rev=829920&r1=829919&r2=829920&view=diff
==============================================================================
--- couchdb/trunk/src/couchdb/couch_rep_changes_feed.erl (original)
+++ couchdb/trunk/src/couchdb/couch_rep_changes_feed.erl Mon Oct 26 19:51:32 2009
@@ -189,12 +189,12 @@
         rows = Rows
     } = State,
     NewState = State#state{count=0, changes_from=nil, rows=queue:new()},
-    ok = maybe_stream_next(NewState),
+    maybe_stream_next(NewState),
     if ChangesFrom =/= nil -> gen_server:reply(ChangesFrom, ok); true -> ok end,
     {reply, queue:to_list(Rows), NewState}.
 
 handle_headers(200, _, State) ->
-    ok = maybe_stream_next(State),
+    maybe_stream_next(State),
     {noreply, State};
 handle_headers(301, Hdrs, State) ->
     catch ibrowse:stop_worker_process(State#state.conn),
@@ -208,7 +208,7 @@
     {stop, {error, Code}, State}.
 
 handle_messages([], State) ->
-    ok = maybe_stream_next(State),
+    maybe_stream_next(State),
     {noreply, State};
 handle_messages([<<"{\"results\":[">>|Rest], State) ->
     handle_messages(Rest, State);



Mime
View raw message