diff options
author | Adam Kocoloski <adam@cloudant.com> | 2010-06-01 10:58:17 -0400 |
---|---|---|
committer | Adam Kocoloski <adam@cloudant.com> | 2010-06-01 10:58:17 -0400 |
commit | bd976a5a78ba88a25996fc7e94c22e8a8925ccec (patch) | |
tree | 4a3ee571dd3a937b166ee246473bce2b71b55885 /src/fabric_open_revs.erl | |
parent | 9b7831dbbddc97b4134be2fa3b3ec2d2ebc9462b (diff) |
add sync_reply, change msg format to be more like gen_server
Diffstat (limited to 'src/fabric_open_revs.erl')
-rw-r--r-- | src/fabric_open_revs.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/fabric_open_revs.erl b/src/fabric_open_revs.erl index 6847a2e5..cc464203 100644 --- a/src/fabric_open_revs.erl +++ b/src/fabric_open_revs.erl @@ -15,11 +15,11 @@ go(DbName, Id, Revs, Options) -> Else end. -handle_message(_Worker, {rexi_DOWN, _, _, _}, Acc0) -> +handle_message({rexi_DOWN, _, _, _}, _Worker, Acc0) -> skip_message(Acc0); -handle_message(_Worker, {rexi_EXIT, _}, Acc0) -> +handle_message({rexi_EXIT, _}, _Worker, Acc0) -> skip_message(Acc0); -handle_message(_Worker, Reply, {WaitingCount, R, Replies}) -> +handle_message(Reply, _Worker, {WaitingCount, R, Replies}) -> case merge_read_reply(make_key(Reply), Reply, Replies) of {_, KeyCount} when KeyCount =:= R -> {stop, Reply}; |