From 04345bd03686e437bbe6d5840e8669518e1762ca Mon Sep 17 00:00:00 2001 From: Benjamin Bastian Date: Fri, 22 Aug 2014 18:39:43 +0700 Subject: [PATCH] Update mem3 for new changes API --- src/mem3_nodes.erl | 2 +- src/mem3_shards.erl | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/mem3_nodes.erl b/src/mem3_nodes.erl index a8c1448..75d336f 100644 --- a/src/mem3_nodes.erl +++ b/src/mem3_nodes.erl @@ -123,7 +123,7 @@ listen_for_changes(Since) -> heartbeat = true, include_docs = true }, - ChangesFun = couch_changes:handle_changes(Args, nil, Db), + ChangesFun = couch_changes:handle_db_changes(Args, nil, Db), ChangesFun(fun changes_callback/2). changes_callback(start, _) -> diff --git a/src/mem3_shards.erl b/src/mem3_shards.erl index 11cf376..cd15a87 100644 --- a/src/mem3_shards.erl +++ b/src/mem3_shards.erl @@ -232,7 +232,7 @@ listen_for_changes(Since) -> heartbeat = true, include_docs = true }, - ChangesFun = couch_changes:handle_changes(Args, Since, Db), + ChangesFun = couch_changes:handle_db_changes(Args, Since, Db), ChangesFun(fun changes_callback/2). changes_callback(start, Acc) ->