couchdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rnew...@apache.org
Subject [44/50] fabric commit: updated refs/heads/master to a71701c
Date Thu, 28 Aug 2014 12:21:19 GMT
squashme! stream_last


Project: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/commit/defcefd0
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/tree/defcefd0
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-fabric/diff/defcefd0

Branch: refs/heads/master
Commit: defcefd0101fa7bac3854c5b04c85c74525a5969
Parents: 7a8244e
Author: Robert Newson <rnewson@apache.org>
Authored: Fri Aug 8 10:17:51 2014 +0100
Committer: Robert Newson <rnewson@apache.org>
Committed: Fri Aug 8 10:17:51 2014 +0100

----------------------------------------------------------------------
 src/fabric_rpc.erl | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/couchdb-fabric/blob/defcefd0/src/fabric_rpc.erl
----------------------------------------------------------------------
diff --git a/src/fabric_rpc.erl b/src/fabric_rpc.erl
index f6d8515..3df0064 100644
--- a/src/fabric_rpc.erl
+++ b/src/fabric_rpc.erl
@@ -64,7 +64,7 @@ changes(DbName, Options, StartVector, DbOptions) ->
         try
             {ok, #cacc{seq=LastSeq, pending=Pending}} =
                 couch_db:changes_since(Db, StartSeq, Enum, Opts, Acc0),
-            rexi:reply({complete, [
+            rexi:stream_last({complete, [
                 {seq, {LastSeq, uuid(Db)}},
                 {pending, Pending}
             ]})
@@ -72,7 +72,7 @@ changes(DbName, Options, StartVector, DbOptions) ->
             couch_db:close(Db)
         end;
     Error ->
-        rexi:reply(Error)
+        rexi:stream_last(Error)
     end.
 
 all_docs(DbName, Options, #mrargs{keys=undefined} = Args0) ->


Mime
View raw message