the decision L51: * to run a particular event is made during the state change, but the decision to actually invoke L52: * the listeners can be delayed slightly so that locks can be dropped. Also, because {@link L53: * #dispatch} is expected to be called concurrently, it is idempotent. L54: */ L55:@J2ktIncompatible L56:@GwtIncompatible L57:@ElementTypesAreNonnullByDefault L58:final class ListenerCallQueue<L> { L59: // TODO(cpovirk): consider using the logger associated with listener.getClass(). L60:...

License. L15: */ L16:package org.codelibs.fess.validation; L17: L18:import static java.lang.annotation.ElementType.ANNOTATION_TYPE; L19:import static java.lang.annotation.ElementType.CONSTRUCTOR; L20:import static java.lang.annotation.ElementType.FIELD; L21:import static java.lang.annotation.ElementType.METHOD; L22:import static java.lang.annotation.ElementType.PARAMETER; L23:import static java.lang.annotation.RetentionPolicy.RUNTIME; L24: L25:import java.lang.annotation.Documented; L26:import j...

<p>A "lock-like object" is really any object that may be used for concurrency control. If the L40: * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a L41: * method equivalent to {@link java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. If L42: * the {@link #callAndAssertWaits} method is ever called in a test, the lock-like object must have a L43: * method equivalent to {@link L44: * java.util.concurrent.locks.ReentrantLock#hasWaiters(jav...

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: // =================================================================================== L75: // Basic Override L76: //...

java.io.IOException L20:import okhttp3.ExperimentalOkHttpApi L21:import okio.BufferedSink L22: L23:/** L24: * The body of a [MockResponse]. L25: * L26: * Unlike [okhttp3.ResponseBody], this interface is designed to be implemented by writers and not L27: * called by readers. L28: */ L29:@ExperimentalOkHttpApi L30:interface MockResponseBody { L31: /** The length of this response in bytes, or -1 if unknown. */ L32: val contentLength: Long L33: L34: @Throws(IOException::class) L35: fun writeTo(sink: BufferedSink)...

List<InetAddress>, L30:) : Dns { L31: @Throws(UnknownHostException::class) L32: override fun lookup(hostname: String): List<InetAddress> { L33: if (this.dnsHostname != hostname) { L34: throw UnknownHostException( L35: "BootstrapDns called for $hostname instead of $dnsHostname", L36: ) L37: } L38: L39: return dnsServers L40: } L41:}...

assertThat(response.handshake!!.localPrincipal).isNull() L74: assertThat(response.handshake!!.peerCertificates).isEmpty() L75: assertThat(response.handshake!!.peerPrincipal).isNull() L76: } L77: L78: @Test fun `bad certificates host in insecureHosts fails with SSLException`() { L79: val heldCertificate = L80: HeldCertificate.Builder() L81: .addSubjectAlternativeName("example.com") L82: .build() L83: val serverCertificates = L84: HandshakeCertificates.Builder() L85: ...

= true)) { L109: namesAndValues.removeAt(i) // name L110: namesAndValues.removeAt(i) // value L111: i -= 2 L112: } L113: i += 2 L114: } L115: } L116: L117:/** L118: * Set a field with the specified value. If the field is not found, it is added. If the field is L119: * found, the existing values are replaced. L120: */ L121:internal fun Headers.Builder.commonSet( L122: name: String, L123: value: String, L124:) = apply { L125: headersCheckName(name) L126: head...

one of the methods in the {@link Futures#immediateFuture Futures.immediate*} L87: * family. <b>Avoid</b> creating a mock or stub {@code Future}. Mock and stub implementations are L88: * fragile because they assume that only certain methods will be called and because they often L89: * implement subtleties of the API improperly. L90: * L91: * <p><b>Custom implementation</b>: Avoid implementing {@code ListenableFuture} from scratch. If you L92: * can't get by with the standard implementations, prefer...

V>> cellIterator() { L314: throw new AssertionError("should never be called"); L315: } L316: L317: @Override L318: public ImmutableCollection<V> values() { L319: return (ImmutableCollection<V>) super.values(); L320: } L321: L322: @Override L323: abstract ImmutableCollection<V> createValues(); L324: L325: @Override L326: final Iterator<V> valuesIterator() { L327: throw new AssertionError("should never be called"); L328: } L329: L330: /** L331: * {@inheritDoc} L332: * L333: ...