Exception { L169: SettableFuture<Object> async = SettableFuture.create(); L170: SettableFuture<Object> inner = SettableFuture.create(); L171: async.setFuture(inner); L172: async.cancel(false); L173: assertTrue(inner.isCancelled()); L174: assertFalse(inner.wasInterrupted()); L175: assertThrows(CancellationException.class, () -> inner.get()); L176: } L177: L178: public void testCancel_beforeSet() throws Exception { L179: SettableFuture<Object> async = SettableFuture.create();...

the master so that it can later verify that {@link L53: * PeekingIterator#remove()} removes the same elements as the reference's iterator {@code L54: * #remove()}. L55: */ L56: private static class PeekingIteratorTester<T extends @Nullable Object> extends IteratorTester<T> { L57: private Iterable<T> master; L58: private @Nullable List<T> targetList; L59: L60: public PeekingIteratorTester(Collection<T> master) { L61: super(master.size() + 3, MODIFIABLE, master, IteratorTester...

return ITEM_ENDPOINT_SUFFIX + "/" + dictId; L58: } L59: L60: @Override L61: protected String getDictType() { L62: return DICT_TYPE; L63: } L64: L65: @Override L66: protected Map<String, Object> createTestParam(int id) { L67: final Map<String, Object> requestBody = new HashMap<>(); L68: final String keyProp = NAME_PREFIX + id; L69: requestBody.put(KEY_PROPERTY, keyProp); L70: requestBody.put("segmentation", "segment"); L71: requestBody.put("reading",...

====== L61: @Override L62: public Map<String, Object> toSource() { L63: Map<String, Object> sourceMap = new HashMap<>(); L64: if (name != null) { L65: addFieldToSource(sourceMap, "name", name); L66: } L67: return sourceMap; L68: } L69: L70: protected void addFieldToSource(Map<String, Object> sourceMap, String field, Object value) { L71: sourceMap.put(field, value); L72: } L73: L74: // ============...

searchEngineClient; L73: L74: @Resource L75: protected QueryHelper queryHelper; L76: L77: @Resource L78: protected SearchHelper searchHelper; L79: L80: @Resource L81: protected HttpServletRequest request; L82: L83: public List<Map<String, Object>> documentItems; L84: L85: public String pageSize; L86: L87: public String currentPageNumber; L88: L89: public String allRecordCount; L90: L91: public String allPageCount; L92: L93: public boolean existNextPage; L94: L95: public...

@SuppressWarnings("FutureReturnValueIgnored") L195: @Override L196: public Object getImpl() { L197: return future; L198: } L199: }; L200: } L201: }, L202: OLD_ABSTRACT_FUTURE { L203: @Override L204: ExecutionListWrapper newExecutionList() { L205: return new ExecutionListWrapper() { L206: final OldAbstractFuture<Object> future = new OldAbstractFuture<Object>() {}; L207: L208: @Override L209: public void add(Runnable...

L47: } L48: L49: @Override L50: public int compareTo(Object object) { L51: // This method is spec'd to throw CCE if object is of the wrong type L52: LegacyComparable that = (LegacyComparable) object; L53: return this.value.compareTo(that.value); L54: } L55: L56: @Override L57: public boolean equals(@Nullable Object object) { L58: if (object instanceof LegacyComparable) { L59: LegacyComparable that = (LegacyComparable) object; L60: return this.value.equals(that.value); L61:...

to access {}.", processingUrl, e); L193: } L194: } L195: } L196: } L197: } L198: L199: protected long getMaxAccessCount(final DataStoreParams paramMap, final Map<String, Object> dataMap) { L200: final Object recursive = dataMap.remove(getParamValue(paramMap, "field.recursive", "recursive")); L201: if (recursive == null || Constants.FALSE.equalsIgnoreCase(recursive.toString())) { L202: return 1L; L203: } L204:...

ntMap; L27:import java.util.concurrent.ExecutionException; L28:import javax.annotation.CheckForNull; L29: L30:/** L31: * A semi-persistent mapping from keys to values. Cache entries are manually added using {@link L32: * #get(Object, Callable)} or {@link #put(Object, Object)}, and are stored in the cache until either L33: * evicted or manually invalidated. The common way to build instances is using {@link CacheBuilder}. L34: * L35: * <p>Implementations of this interface are expected to be thread-safe,...

return LIST_ENDPOINT_SUFFIX; L53: } L54: L55: @Override L56: protected String getItemEndpointSuffix() { L57: return ITEM_ENDPOINT_SUFFIX; L58: } L59: L60: @Override L61: protected Map<String, Object> createTestParam(int id) { L62: final Map<String, Object> requestBody = new HashMap<>(); L63: final String keyProp = NAME_PREFIX + id; L64: final String urls = "http://" + NAME_PREFIX + id; L65: requestBody.put(KEY_PROPERTY, keyProp); L66: req...