(e1, e2) -> { L535: // requireNonNull is safe because the first `size` elements have been filled in. L536: requireNonNull(e1); L537: requireNonNull(e2); L538: return comparator.compare(e1.getKey(), e2.getKey()); L539: }); L540: // requireNonNull is safe because the first `size` elements have been filled in. L541: Entry<K, V> firstEntry = requireNonNull(entryArray[0]); L542: K prevKey = firstEntry.getKey();...

======== L86: L87: protected AvgAggregationBuilder regAvgA(String name, String field) { L88: AvgAggregationBuilder builder = AggregationBuilders.avg(name).field(field); L89: regA(builder); L90: return builder; L91: } L92: L93: protected MaxAggregationBuilder regMaxA(String name, String field) { L94: MaxAggregationBuilder builder = AggregationBuilders.max(name).field(field); L95: regA(builder); L96: return builder; L97: } L98: L99: protected...

fields L39: L40: /** The HTTP {@code Cache-Control} header field name. */ L41: public static final String CACHE_CONTROL = "Cache-Control"; L42: /** The HTTP {@code Content-Length} header field name. */ L43: public static final String CONTENT_LENGTH = "Content-Length"; L44: /** The HTTP {@code Content-Type} header field name. */ L45: public static final String CONTENT_TYPE = "Content-Type"; L46: /** The HTTP {@code Date} header field name. */ L47: public static final String DATE = "Date"; L48:...

(SORT_FIELD.equals(field)) { L79: return convertSortQuery(fessConfig, context, termQuery, boost, field, text); L80: } L81: if (SITE_FIELD.equals(field)) { L82: return convertSiteQuery(fessConfig, context, termQuery, boost, field, text); L83: } L84: if (INURL_FIELD.equals(field) L85: || StringUtil.equals(field, context.getDefaultField()) && fessConfig.getIndexFieldUrl().equals(context.getDefaultField())) { L86: return convertWildcardQuery(fessConfig,...

kotlin.jvm.JvmStatic L19: L20:object HttpMethod { L21: @JvmStatic // Despite being 'internal', this method is called by popular 3rd party SDKs. L22: fun invalidatesCache(method: String): Boolean = L23: ( L24: method == "POST" || method == "PATCH" || method == "PUT" || L25: method == "DELETE" || method == "MOVE" L26: ) L27: L28: @JvmStatic // Despite being 'internal', this method is called by popular 3rd party SDKs. L29: fun requiresRequestBody(method: String): Boolean = L30: ( L31: ...

override fun evaluate() { L35: called.set(true) L36: rule.server.url("/").toUrl().openConnection().connect() L37: } L38: }, L39: Description.EMPTY, L40: ) L41: statement.evaluate() L42: assertThat(called.get()).isTrue() L43: try { L44: rule.server.url("/").toUrl().openConnection().connect() L45: fail() L46: } catch (expected: ConnectException) { L47: } L48: } L49:}...

Future<?> possiblyIgnoredError1 = serializer.submitAsync(thirdCallable, directExecutor()); L85: secondFuture.cancel(true); L86: assertThat(secondCallable.called).isFalse(); L87: assertThat(thirdCallable.called).isFalse(); L88: firstFuture.set(null); L89: assertThat(secondCallable.called).isFalse(); L90: assertThat(thirdCallable.called).isTrue(); L91: } L92: L93: public void testCancellationMultipleThreads() throws Exception { L94: final BlockingCallable blockingCallable = new BlockingCallable();...

private final Object monitor = new Object(); L68: private boolean called = false; L69: L70: @Override L71: public void onSuccess(String result) { L72: fail("Was not expecting onSuccess() to be called."); L73: } L74: L75: @Override L76: public void onFailure(Throwable t) { L77: synchronized (monitor) { L78: assertFalse(called); L79: assertThat(t).isInstanceOf(CancellationException.class); L80:...

return iterator.hasNext(); L940: } L941: L942: @Override L943: @ParametricNullness L944: public T next() { L945: T result = iterator.next(); L946: atStart = false; // not called if next() fails L947: return result; L948: } L949: L950: @Override L951: public void remove() { L952: checkRemove(!atStart); L953: iterator.remove(); L954: } L955: }; L956: }...

before, during, or after runInterruptibly() (unless it produced an InterruptedException L162: * caught above) can linger and affect listeners. L163: */ L164: } L165: L166: /** L167: * Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not L168: * be called. L169: */ L170: abstract boolean isDone(); L171: L172: /** L173: * Do interruptible work here - do not complete Futures here, as their listeners could be L174: * interrupted. L175: */...