builder = builder.callTimeout(0L, TimeUnit.SECONDS)
    builder = builder.callTimeout(Duration.ofSeconds(0L))
    builder = builder.connectTimeout(0L, TimeUnit.SECONDS)
    builder = builder.connectTimeout(Duration.ofSeconds(0L))
    builder = builder.readTimeout(0L, TimeUnit.SECONDS)
    builder = builder.readTimeout(Duration.ofSeconds(0L))
    builder = builder.writeTimeout(0L, TimeUnit.SECONDS)

    eventRecorder.takeEvent(ResponseHeadersEnd::class.java, 0L)
    eventRecorder.takeEvent(FollowUpDecision::class.java, 0L)
    eventRecorder.takeEvent(ResponseBodyStart::class.java, responseBodyStartDelay)
    eventRecorder.takeEvent(ResponseBodyEnd::class.java, responseBodyEndDelay)
    eventRecorder.takeEvent(ConnectionReleased::class.java, 0L)
    eventRecorder.takeEvent(CallEnd::class.java, 0L)
  }

  private fun enableTlsWithTunnel() {

        return new ChatSearchResult(Collections.emptyList(), null, 0L);
    }

    /**
     * Validates a query and returns an empty result if invalid, or null if validation passed.
     */
    private ChatSearchResult validateQuery(final String query) {
        if (StringUtil.isBlank(query)) {
            return new ChatSearchResult(Collections.emptyList(), null, 0L);
        }
        if (query.length() > MAX_QUERY_LENGTH) {

      it.assertValue(1, "a")
    }
    assertThat(cache.size()).isEqualTo(0L)
  }

  @Test
  fun editSnapshotAfterEvictAllReturnsNullDueToStaleValue() {
    val expectedByteCount = if (windows) 2L else 0L
    val afterRemoveFileContents = if (windows) "a" else null

    set("a", "a", "a")
    cache["a"]!!.use {
      cache.evictAll()

    connection.okHttpSettings[Settings.INITIAL_WINDOW_SIZE] = windowSize
    val stream = connection.newStream(headerEntries("b", "banana"), false)
    assertThat(stream.readBytes.acknowledged).isEqualTo(0L)
    assertThat(stream.readBytes.total).isEqualTo(0L)
    assertThat(stream.takeHeaders()).isEqualTo(headersOf("a", "android"))
    val source = stream.source
    val buffer = Buffer()
    buffer.writeAll(source)

        final Map<String, Object> map = Map.of("time", "not_a_number");
        assertEquals(0L, coordinatorHelper.getLongValue(map, "time"));
    }

    @Test
    public void test_getLongValue_missing() {
        final Map<String, Object> map = Map.of("key", "value");
        assertEquals(0L, coordinatorHelper.getLongValue(map, "key"));
    }

     * stability checks.
     */
    long sum = 0L;
    Segment<K, V, E, S>[] segments = this.segments;
    for (int i = 0; i < segments.length; ++i) {
      if (segments[i].count != 0) {
        return false;
      }
      sum += segments[i].modCount;
    }

    if (sum != 0L) { // recheck unless no modifications
      for (int i = 0; i < segments.length; ++i) {

     * stability checks.
     */
    long sum = 0L;
    Segment<K, V, E, S>[] segments = this.segments;
    for (int i = 0; i < segments.length; ++i) {
      if (segments[i].count != 0) {
        return false;
      }
      sum += segments[i].modCount;
    }

    if (sum != 0L) { // recheck unless no modifications
      for (int i = 0; i < segments.length; ++i) {

   * exhausted: its {@code hasNext()} method will return {@code false}.
   */
  public static int size(Iterator<?> iterator) {
    long count = 0L;
    while (iterator.hasNext()) {
      iterator.next();
      count++;
    }
    return Ints.saturatedCast(count);
  }

  /** Returns {@code true} if {@code iterator} contains {@code element}. */

   * exhausted: its {@code hasNext()} method will return {@code false}.
   */
  public static int size(Iterator<?> iterator) {
    long count = 0L;
    while (iterator.hasNext()) {
      iterator.next();
      count++;
    }
    return Ints.saturatedCast(count);
  }

  /** Returns {@code true} if {@code iterator} contains {@code element}. */