Skip to content

Commit 4c0b6ae

Browse files
committed
SDKQE-3842 FIT: Implement closeQueryResult
1 parent 933c82d commit 4c0b6ae

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

couchbase-analytics-java-client/fit/src/main/java/com/couchbase/analytics/fit/performer/rpc/JavaAnalyticsCrossService.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,11 +147,16 @@ public void queryMetadata(QueryMetadataRequest request, StreamObserver<QueryResu
147147

148148
@Override
149149
public void closeQueryResult(CloseQueryResultRequest request, StreamObserver<EmptyResultOrFailureResponse> responseObserver) {
150-
super.closeQueryResult(request, responseObserver);
150+
noop(responseObserver);
151151
}
152152

153153
@Override
154154
public void closeAllQueryResults(CloseAllQueryResultsRequest request, StreamObserver<EmptyResultOrFailureResponse> responseObserver) {
155-
super.closeAllQueryResults(request, responseObserver);
155+
noop(responseObserver);
156+
}
157+
158+
private static void noop(StreamObserver<EmptyResultOrFailureResponse> responseObserver) {
159+
responseObserver.onNext(ResultUtil.success(startTiming()));
160+
responseObserver.onCompleted();
156161
}
157162
}

0 commit comments

Comments
 (0)