diff options
| author | Bessenyei Balázs Donát <bessbd@apache.org> | 2021-03-05 13:36:53 +0100 |
|---|---|---|
| committer | Bessenyei Balázs Donát <bessbd@users.noreply.github.com> | 2021-03-11 23:38:34 +0100 |
| commit | 63700c38dfe5f0c023e243362cd7101d5ec09058 (patch) | |
| tree | 3d77d2558ab3df3959283f14a625c17f96a60c3e /src | |
| parent | 82bd4d450711b0ff62616229851e5d19fd20e42f (diff) | |
| download | couchdb-63700c38dfe5f0c023e243362cd7101d5ec09058.tar.gz | |
Fix and re-enable ChangesAsyncTest
Diffstat (limited to 'src')
| -rw-r--r-- | src/chttpd/src/chttpd_db.erl | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/chttpd/src/chttpd_db.erl b/src/chttpd/src/chttpd_db.erl index 7b4fdef9c..ac3d3b159 100644 --- a/src/chttpd/src/chttpd_db.erl +++ b/src/chttpd/src/chttpd_db.erl @@ -222,9 +222,13 @@ changes_callback(waiting_for_updates, Acc) -> mochi = Resp1, chunks_sent = ChunksSent + 1 }}; -changes_callback({timeout, _ResponseType}, Acc) -> +changes_callback({timeout, ResponseType}, Acc) -> #cacc{mochi = Resp, chunks_sent = ChunksSent} = Acc, - {ok, Resp1} = chttpd:send_delayed_chunk(Resp, "\n"), + Chunk = case ResponseType of + "eventsource" -> "event: heartbeat\ndata: \n\n"; + _ -> "\n" + end, + {ok, Resp1} = chttpd:send_delayed_chunk(Resp, Chunk), {ok, Acc#cacc{mochi = Resp1, chunks_sent = ChunksSent + 1}}; changes_callback({error, Reason}, #cacc{mochi = #httpd{}} = Acc) -> #cacc{mochi = Req} = Acc, |