This is an automated email from the ASF dual-hosted git repository. rnewson pushed a commit to branch nouveau-ibrowse-improvements in repository https://gitbox.apache.org/repos/asf/couchdb.git
commit e08a25e273abb3baeae637a9d043436e7d2abca2 Author: Robert Newson <[email protected]> AuthorDate: Mon Sep 4 22:43:27 2023 +0100 fixup Async --- src/nouveau/src/nouveau_api.erl | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/nouveau/src/nouveau_api.erl b/src/nouveau/src/nouveau_api.erl index c5d147fb2..f272bafec 100644 --- a/src/nouveau/src/nouveau_api.erl +++ b/src/nouveau/src/nouveau_api.erl @@ -197,10 +197,13 @@ drain_async_responses_list([]) -> drain_async_responses_list([ReqId | Rest]) -> receive {ibrowse_async_headers, ReqId, Code, Headers} -> - drain_async_response(ReqId, Code, Headers, undefined) - end, - drain_async_responses_list(Rest). - + case drain_async_response(ReqId, Code, Headers, undefined) of + {ok, "204", _Headers, _Body} -> + drain_async_responses_list(Rest); + {ok, StatusCode, _Headers, RespBody} -> + exit({error, jaxrs_error(StatusCode, RespBody)}) + end + end. drain_async_responses_timeout(Timeout, ReqIds) when is_integer(Timeout); Timeout == infinity -> receive
