Repository: marmotta Updated Branches: refs/heads/develop 7275a000e -> 8c130aef7
Ostrich Client: minor fix to conform to new gRPC API Project: http://git-wip-us.apache.org/repos/asf/marmotta/repo Commit: http://git-wip-us.apache.org/repos/asf/marmotta/commit/8c130aef Tree: http://git-wip-us.apache.org/repos/asf/marmotta/tree/8c130aef Diff: http://git-wip-us.apache.org/repos/asf/marmotta/diff/8c130aef Branch: refs/heads/develop Commit: 8c130aef76136b1a8329ccbedf097fbc0581de71 Parents: 7275a00 Author: Sebastian Schaffert <[email protected]> Authored: Sat Nov 19 13:44:10 2016 +0100 Committer: Sebastian Schaffert <[email protected]> Committed: Sat Nov 19 13:44:10 2016 +0100 ---------------------------------------------------------------------- .../org/apache/marmotta/ostrich/sail/ClosableResponseStream.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/marmotta/blob/8c130aef/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java ---------------------------------------------------------------------- diff --git a/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java b/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java index 35d8ada..e9ec41e 100644 --- a/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java +++ b/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java @@ -57,7 +57,7 @@ public class ClosableResponseStream<Svc extends AbstractStub<Svc>, ReqT, T> impl call.sendMessage(req); call.halfClose(); } catch (Throwable t) { - call.cancel(); + call.cancel("Error", t); throw new SailException(t); } } @@ -72,7 +72,7 @@ public class ClosableResponseStream<Svc extends AbstractStub<Svc>, ReqT, T> impl */ @Override public void close() throws SailException { - call.cancel(); + call.cancel("Closed by client", null); } /**
