From d6ca78c9c09e88e84b303ebcb5d355e148ebcc7d Mon Sep 17 00:00:00 2001 From: Adam Kocoloski Date: Mon, 26 Oct 2009 19:51:32 +0000 Subject: _changes response might have completed already git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@829920 13f79535-47bb-0310-9956-ffa450edef68 --- src/couchdb/couch_rep_changes_feed.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'src/couchdb') 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); -- cgit v1.2.3