diff options
| author | ILYA Khlopotov <iilyak@apache.org> | 2017-06-27 10:00:02 -0700 |
|---|---|---|
| committer | ILYA Khlopotov <iilyak@apache.org> | 2017-06-27 10:00:02 -0700 |
| commit | 4396891560b70336d340f438a458acecbaff9754 (patch) | |
| tree | 2c8bf9beb803b4ed69ffc703418c2d656a913223 | |
| parent | 628ca7e2fec369ac4622842d78630027f527e529 (diff) | |
| download | couchdb-4396891560b70336d340f438a458acecbaff9754.tar.gz | |
Allow wait_updated to switch to new module code
| -rw-r--r-- | src/couch/src/couch_changes.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/couch/src/couch_changes.erl b/src/couch/src/couch_changes.erl index 11d0d8d4c..861c81a8e 100644 --- a/src/couch/src/couch_changes.erl +++ b/src/couch/src/couch_changes.erl @@ -30,7 +30,10 @@ -export([changes_enumerator/2]). %% export so we can use fully qualified call to facilitate hot-code upgrade --export([keep_sending_changes/3]). +-export([ + keep_sending_changes/3, + wait_updated/3 +]). -record(changes_acc, { db, @@ -870,7 +873,7 @@ wait_updated(Timeout, TimeoutFun, UserAcc) -> {Go, UserAcc2} = TimeoutFun(UserAcc), case Go of ok -> - wait_updated(Timeout, TimeoutFun, UserAcc2); + ?MODULE:wait_updated(Timeout, TimeoutFun, UserAcc2); stop -> {stop, UserAcc2} end |