summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/couchdb/couch_rep_changes_feed.erl1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/couchdb/couch_rep_changes_feed.erl b/src/couchdb/couch_rep_changes_feed.erl
index c124af1b..a358bed5 100644
--- a/src/couchdb/couch_rep_changes_feed.erl
+++ b/src/couchdb/couch_rep_changes_feed.erl
@@ -199,6 +199,7 @@ handle_response({error, Reason}, State) ->
{stop, {error, Reason}, State};
handle_response(<<"\n">>, State) ->
?LOG_DEBUG("got a heartbeat from the remote server", []),
+ ok = maybe_stream_next(State),
{noreply, State};
handle_response(<<"{\"results\":[\n">>, State) ->
ok = maybe_stream_next(State),