null) { L137: addFieldToSource(sourceMap, "updatedTime", updatedTime); L138: } L139: return sourceMap; L140: } L141: L142: protected void addFieldToSource(Map<String, Object> sourceMap, String field, Object value) { L143: sourceMap.put(field, value); L144: } L145: L146: // =================================================================================== L147: // Basic Override L148:...

extends TestCase { L33: L34: public void testSubmit() throws Exception { L35: /* L36: * Mostly just tests that TrustedListenableFutureTask are created and run; tests for L37: * TrustedListenableFutureTask should ensure that listeners are called correctly. L38: */ L39: L40: TestListeningExecutorService e = new TestListeningExecutorService(); L41: L42: TestRunnable runnable = new TestRunnable(); L43: ListenableFuture<?> runnableFuture = e.submit(runnable); L44: assertThat(...

extends TestCase { L33: L34: public void testSubmit() throws Exception { L35: /* L36: * Mostly just tests that TrustedListenableFutureTask are created and run; tests for L37: * TrustedListenableFutureTask should ensure that listeners are called correctly. L38: */ L39: L40: TestListeningExecutorService e = new TestListeningExecutorService(); L41: L42: TestRunnable runnable = new TestRunnable(); L43: ListenableFuture<?> runnableFuture = e.submit(runnable); L44: assertThat(...

imeUnit; L30:import java.util.concurrent.atomic.AtomicLong; L31: L32:/** L33: * A Ticker whose value can be advanced programmatically in test. L34: * L35: * <p>The ticker can be configured so that the time is incremented whenever {@link #read} is called: L36: * see {@link #setAutoIncrementStep}. L37: * L38: * <p>This class is thread-safe. L39: * L40: * @author Jige Yu L41: * @since 10.0 L42: */ L43:@ElementTypesAreNonnullByDefault L44:@GwtCompatible L45:public class FakeTicker extends Ticker { L46:...

IOException { L58: hasher.putBytes(bytes, off, len); L59: out.write(bytes, off, len); L60: } L61: L62: /** L63: * Returns the {@link HashCode} based on the data written to this stream. The result is L64: * unspecified if this method is called more than once on the same instance. L65: */ L66: public HashCode hash() { L67: return hasher.hash(); L68: } L69: L70: // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior: L71: // it silently ignores...

L161: ) { L162: println("onSucceeded ${info.headers.asMap}") L163: completableFuture.complete(Response(info.httpStatusCode, info.negotiatedProtocol, buffer.readUtf8())) L164: } L165: L166: override fun onFailed( L167: request: UrlRequest, L168: info: UrlResponseInfo?, L169: error: HttpException, L170: ) { L171: println("onSucceeded ${info?.headers?.asMap}") L172: completableFuture.complete...

Encrypt Root Certificate. L32: */ L33:@Tag("Remote") L34:class LetsEncryptClientTest { L35: @Test fun get() { L36: // These tests wont actually run before Android 8.0 as per L37: // https://github.com/mannodermaus/android-junit5 L38: // Raised https://github.com/mannodermaus/android-junit5/issues/228 to reevaluate L39: val androidMorEarlier = Build.VERSION.SDK_INT <= 23 L40: L41: val clientBuilder = OkHttpClient.Builder() L42: L43: if (androidMorEarlier) { L44: val cert: X509Certificate...

L1:public final class okhttp3/android/AndroidAsyncDns : okhttp3/AsyncDns { L2: public static final field Companion Lokhttp3/android/AndroidAsyncDns$Companion; L3: public fun <init> (Lokhttp3/AsyncDns$DnsClass;Landroid/net/Network;)V L4: public synthetic fun <init> (Lokhttp3/AsyncDns$DnsClass;Landroid/net/Network;ILkotlin/jvm/internal/DefaultConstructorMarker;)V L5: public fun query (Ljava/lang/String;Lokhttp3/AsyncDns$Callback;)V L6:} L7: L8:public final class okhttp3/android/AndroidAsyncDns$Companion...

fromEntryArrayCheckingBucketOverflow( L107: int n, @Nullable Entry<K, V>[] entryArray, boolean throwIfDuplicateKeys) L108: throws BucketOverflowException { L109: /* L110: * The cast is safe: n==entryArray.length means that we have filled the whole array with Entry L111: * instances, in which case it is safe to cast it from an array of nullable entries to an array L112: * of non-null entries. L113: */ L114: @SuppressWarnings("nullness") L115: Entry<K, V>[] entries...

else if (nanos <= 0) { L98: return false; L99: } else { L100: long now = System.nanoTime(); L101: NANOSECONDS.timedWait(lock, nanos); L102: nanos -= System.nanoTime() - now; // subtract the actual time we waited L103: } L104: } L105: } L106: } L107: L108: /** L109: * Checks if the executor has been shut down and increments the running task count. L110: * L111: * @throws RejectedExecutionException if the executor has been previously...