summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAdam Kocoloski <kocolosk@apache.org>2009-10-26 19:51:32 +0000
committerAdam Kocoloski <kocolosk@apache.org>2009-10-26 19:51:32 +0000
commitd6ca78c9c09e88e84b303ebcb5d355e148ebcc7d (patch)
tree98e22fa6977100a6678f74e34b9f0db10d476beb /src
parent371db8eefbb1d71ae7495e0ea588016378834ec2 (diff)
_changes response might have completed already
git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@829920 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'src')
-rw-r--r--src/couchdb/couch_rep_changes_feed.erl6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/couchdb/couch_rep_changes_feed.erl b/src/couchdb/couch_rep_changes_feed.erl
index 62c8692a..cdfed6a0 100644
--- a/src/couchdb/couch_rep_changes_feed.erl
+++ b/src/couchdb/couch_rep_changes_feed.erl
@@ -189,12 +189,12 @@ handle_next_changes(_From, State) ->
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 @@ handle_headers(Code, Hdrs, State) ->
{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);