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:...

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(...

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...

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...

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...

AbstractIndexedListIterator<E extends @Nullable Object> L36: extends UnmodifiableListIterator<E> { L37: private final int size; L38: private int position; L39: L40: /** Returns the element with the specified index. This method is called by {@link #next()}. */ L41: @ParametricNullness L42: protected abstract E get(int index); L43: L44: /** L45: * Constructs an iterator across a sequence of the given size whose initial position is 0. That L46: * is, the first call to {@link #next()} will...

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...

FutureCallback<V extends @Nullable Object> { L34: /** Invoked with the result of the {@code Future} computation when it is successful. */ L35: void onSuccess(@ParametricNullness V result); L36: L37: /** L38: * Invoked when a {@code Future} computation fails or is canceled. L39: * L40: * <p>If the future's {@link Future#get() get} method throws an {@link ExecutionException}, then L41: * the cause is passed to this method. Any other thrown object is passed unaltered. L42: */ L43: void onFailure(Throwable...