diff options
| author | Adam Kocoloski <adam@cloudant.com> | 2013-09-12 13:30:14 -0400 |
|---|---|---|
| committer | Adam Kocoloski <adam@cloudant.com> | 2013-10-02 12:11:24 -0400 |
| commit | ba4e8382a2318ea4aab9174f17a84eb0eb41d605 (patch) | |
| tree | 9a8ca05663144900bb3e4f12668166cabe9bfb40 | |
| parent | a3a2a5f6082f2bda9185642a344fd28af9acb348 (diff) | |
| download | couchdb-ba4e8382a2318ea4aab9174f17a84eb0eb41d605.tar.gz | |
Ensure the att reader learns of a Parser death
| -rw-r--r-- | src/couch_replicator/src/couch_replicator_api_wrap.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/couch_replicator/src/couch_replicator_api_wrap.erl b/src/couch_replicator/src/couch_replicator_api_wrap.erl index 28f96c079..d8be12a25 100644 --- a/src/couch_replicator/src/couch_replicator_api_wrap.erl +++ b/src/couch_replicator/src/couch_replicator_api_wrap.erl @@ -713,6 +713,7 @@ doc_from_multi_part_stream(ContentType, DataFun, Ref) -> {doc_bytes, Ref, DocBytes} -> Doc = couch_doc:from_json_obj(?JSON_DECODE(DocBytes)), ReadAttachmentDataFun = fun() -> + link(Parser), Parser ! {get_bytes, Ref, self()}, receive {started_open_doc_revs, NewRef} -> |