assertThrows( L138: UnsupportedOperationException.class, L139: () -> L140: getMap() L141: .computeIfAbsent( L142: k3(), L143: k -> { L144: // allowed to be called L145: assertEquals(k3(), k); L146: return v3(); L147: })); L148: expectUnchanged(); L149: } L150: L151: @MapFeature.Require(absent = SUPPORTS_PUT) L152: @CollectionSize.Require(absent...

override L104: * this method to use a custom {@link Executor}, which may configure its worker thread with a L105: * specific name, thread group or priority. The returned executor's {@link L106: * Executor#execute(Runnable) execute()} method is called when this service is started and L107: * stopped, and should return promptly. L108: */ L109: protected Executor executor() { L110: return command -> MoreExecutors.newThread(threadNameSupplier.get(), command).start(); L111: } L112: L113: ...

new AbstractIterator<Integer>() { L83: boolean haveBeenCalled; L84: L85: @Override L86: public Integer computeNext() { L87: if (haveBeenCalled) { L88: throw new AssertionError("Should not have been called again"); L89: } else { L90: haveBeenCalled = true; L91: sneakyThrow(new SomeCheckedException()); L92: throw new AssertionError(); // unreachable L93: } L94: } L95: }; L96:...

L722: // 1. prior to setFuture L723: // 2. after setFuture before set() on the future assigned L724: // 3. after setFuture and set() are called but before the listener completes. L725: if (!setFutureSetSuccess.get() || !setFutureCompletionSuccess.get()) { L726: // If setFuture fails or set on the future fails then it must be because that future was L727: // cancelled L728: assertTrue(setFuture.isCancelled()); L729: assertTrue(setFuture.wasInterrupted());...

receive the response. L9: L10:#### Blocking APIs L11: L12:Blocking APIs are convenient because you get top-to-bottom procedural code without indirection. Network calls work like regular method calls: ask for data and it is returned. If the request fails, you get a stacktrace right where the call was made. L13: L14:Blocking APIs may be inefficient because you hold a thread idle while waiting on the network. Threads are expensive because they have both a memory overhead and a context-switching overhead....

// we reached EOF L78: return new String(buffer, 0, bufIndex); L79: } L80: // otherwise we got the size wrong. This can happen if the size changes between when L81: // we called sizeIfKnown and when we started reading the file (or I guess if L82: // maxCharsPerByte is wrong) L83: // Fallback to an incremental approach L84: StringBuilder builder = new StringBuilder(bufIndex + 32); L85: builder.append(buffer,...

ways: L42: L43: * **Synchronous:** your thread blocks until the response is readable. L44: * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable. L45: L46:Calls can be canceled from any thread. This will fail the call if it hasn’t yet completed! Code that is writing the request body or reading the response body will suffer an `IOException` when its call is canceled....

or {@code null} if no escaping was needed L82: */ L83: @CheckForNull L84: protected abstract char[] escape(char c); L85: L86: /** L87: * Returns the escaped form of a given literal string, starting at the given index. This method is L88: * called by the {@link #escape(String)} method when it discovers that escaping is required. It is L89: * protected to allow subclasses to override the fastpath escaping function to inline their L90: * escaping test. See {@link CharEscaperBuilder} for an...

: indicates an upgrade L12: L13: L14: L15:# Sets the default values for fess variables used in this script L16:FESS_USER="${packaging.fess.user}" L17:FESS_GROUP="${packaging.fess.group}" L18: L19:# Source the default env file L20:FESS_ENV_FILE="${packaging.env.file}" L21:if [ -f "$FESS_ENV_FILE" ]; then L22: . "$FESS_ENV_FILE" L23:fi L24: L25:IS_UPGRADE=false L26: L27:case "$1" in L28: L29: # Debian #################################################### L30: configure) L31: L32: ...

ass) L79: registerTest(access, testClass) L80: } L81: } catch (e: Exception) { L82: // If you throw an exception here then native image building fails half way through L83: // silently without rewriting the binary. So we report noisily, but keep going and prefer L84: // running most tests still. L85: e.printStackTrace() L86: } L87: } L88: } L89: L90: private fun registerTest( L91: access: Feature.BeforeAnalysisAccess, L92: java: Class<*>,...