service.notifyFailed(new Exception("1"));
    service.notifyFailed(new Exception("2"));
    assertThat(service.failureCause()).hasMessageThat().isEqualTo("1");
    IllegalStateException e = assertThrows(IllegalStateException.class, service::awaitRunning);
    assertThat(e).hasCauseThat().hasMessageThat().isEqualTo("1");
  }

  private class ThreadedService extends AbstractService {

    service.notifyFailed(new Exception("1"));
    service.notifyFailed(new Exception("2"));
    assertThat(service.failureCause()).hasMessageThat().isEqualTo("1");
    IllegalStateException e = assertThrows(IllegalStateException.class, service::awaitRunning);
    assertThat(e).hasCauseThat().hasMessageThat().isEqualTo("1");
  }

  private class ThreadedService extends AbstractService {

            "This is a line\r\nThis too\rand this\nand also this".getBytes(UTF_8));
    assertThat(in.readLine()).isEqualTo("This is a line");
    assertThat(in.readLine()).isEqualTo("This too");
    assertThat(in.readLine()).isEqualTo("and this");
    assertThat(in.readLine()).isEqualTo("and also this");
  }

  public void testNewDataInput_readFloat() {

    assertThat("☃.net".toCanonicalHost()).isEqualTo("xn--n3h.net")

    // IPv4 Compatible or Mapped addresses
    assertThat("::192.168.0.1".toCanonicalHost()).isEqualTo("::c0a8:1")
    assertThat("::FFFF:192.168.0.1".toCanonicalHost()).isEqualTo("192.168.0.1")
    assertThat("0:0:0:0:0:0:13.1.68.3".toCanonicalHost()).isEqualTo("::d01:4403")
    assertThat("::13.1.68.3".toCanonicalHost()).isEqualTo("::d01:4403")

    assertThat(responseA.body.string()).isEqualTo("a")
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    val responseB = client.newCall(request).execute()
    assertThat(responseB.body.string()).isEqualTo("b")
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
    assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
  }

  @Test

        assertThat(cache.getUnchecked(entry.getKey())).isEqualTo(newValue);
        assertThat(cache.getUnchecked(newKey)).isEqualTo(entry.getValue());
        // don't let the new entry get GCed
        warmed.add(entryOf(newKey, entry.getValue()));
      }
      assertThat(cache.stats().missCount()).isEqualTo(WARMUP_SIZE);
      checkValidState(cache);
    }
  }

    assertThat(httpUrl.toUri().toString()).isEqualTo("http://\$tracker/")
  }

  @Test
  fun fragmentNonAsciiThatOffendsJavaNetUri() {
    val url = "http://host/#\u0080".toHttpUrl()
    assertThat(url.toString()).isEqualTo("http://host/#\u0080")
    assertThat(url.fragment).isEqualTo("\u0080")
    assertThat(url.encodedFragment).isEqualTo("\u0080")
    // Control characters may be stripped!

    Converter<String, TestEnum> converter = Enums.stringConverter(TestEnum.class);
    assertThat(converter.reverse().convert(TestEnum.CHEETO)).isEqualTo("CHEETO");
    assertThat(converter.reverse().convert(TestEnum.HONDA)).isEqualTo("HONDA");
    assertThat(converter.reverse().convert(TestEnum.POODLE)).isEqualTo("POODLE");
  }

  @J2ktIncompatible
  public void testStringConverter_nullPointerTester() throws Exception {

    val call = client.newCall(networkRequest)

    call.execute().use { response ->
      assertThat(response.code).isEqualTo(200)
      assertThat(response.cacheResponse).isNull()
    }

    val cachedCall = client.newCall(request)

    cachedCall.execute().use { response ->
      assertThat(response.code).isEqualTo(200)
      assertThat(response.cacheResponse).isNotNull()
    }
  }

  @Test

          }.buffer()
        }
      }
    assertThat(body.source().readUtf8()).isEqualTo("hello")
    body.close()
  }

  @Test
  fun unicodeText() {
    val text = "eile oli oliiviõli"
    val body = text.toResponseBody()
    assertThat(body.string()).isEqualTo(text)
  }

  @Test
  fun unicodeTextWithCharset() {
    val text = "eile oli oliiviõli"