diff options
author | Jon Bratseth <bratseth@verizonmedia.com> | 2020-01-07 10:53:20 +0100 |
---|---|---|
committer | Jon Bratseth <bratseth@verizonmedia.com> | 2020-01-07 10:53:20 +0100 |
commit | ec9c2299c72558f82487db6c8ff5759bff430968 (patch) | |
tree | 068162da8337a7b462963d51d7112ac0679ff926 /vespa-http-client/src | |
parent | a63642e0c917fb323f53377d6644ef1126cad9eb (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.java | 20 |
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) { |