aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-http-client/src
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@verizonmedia.com>2020-01-07 10:53:20 +0100
committerJon Bratseth <bratseth@verizonmedia.com>2020-01-07 10:53:20 +0100
commitec9c2299c72558f82487db6c8ff5759bff430968 (patch)
tree068162da8337a7b462963d51d7112ac0679ff926 /vespa-http-client/src
parenta63642e0c917fb323f53377d6644ef1126cad9eb (diff)
Remove beta: In heavy use for a year
Diffstat (limited to 'vespa-http-client/src')
-rw-r--r--vespa-http-client/src/main/java/com/yahoo/vespa/http/client/SyncFeedClient.java20
1 files changed, 1 insertions, 19 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/SyncFeedClient.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/SyncFeedClient.java
index 96af9e7e278..66ef71fb730 100644
--- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/SyncFeedClient.java
+++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/SyncFeedClient.java
@@ -1,7 +1,6 @@
// Copyright 2020 Oath Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.http.client;
-import com.google.common.annotations.Beta;
import com.yahoo.vespa.http.client.config.SessionParams;
import java.math.BigInteger;
@@ -21,7 +20,6 @@ import java.util.concurrent.ThreadLocalRandom;
*
* @author bratseth
*/
-@Beta
public class SyncFeedClient implements AutoCloseable {
private final FeedClient wrappedClient;
@@ -128,23 +126,6 @@ public class SyncFeedClient implements AutoCloseable {
*/
private LinkedHashMap<String, Result> results = null;
- void resetExpectedResults() {
- synchronized (monitor) {
- if (results != null)
- throw new ConcurrentModificationException("A SyncFeedClient instance is used by multiple threads");
-
- resultsReceived = 0;
- exception = null;
- results = new LinkedHashMap<>();
- }
- }
-
- void addExpectationOfResultFor(String operationId) {
- synchronized (monitor) {
- results.put(operationId, null);
- }
- }
-
void expectResultsOf(List<SyncOperation> operations) {
synchronized (monitor) {
if (results != null)
@@ -157,6 +138,7 @@ public class SyncFeedClient implements AutoCloseable {
results.put(operation.operationId, null);
}
}
+
SyncResult waitForResults() {
try {
synchronized (monitor) {