assertThat(header.tag).isEqualTo(2L)
      assertThat(header.tagClass).isEqualTo(DerHeader.TAG_CLASS_CONTEXT_SPECIFIC)
      assertThat(header.length).isEqualTo(7L)

      derReader.read("test") { header ->
        assertThat(header.tag).isEqualTo(3L)
        assertThat(header.tagClass).isEqualTo(DerHeader.TAG_CLASS_APPLICATION)
        assertThat(header.length).isEqualTo(5L)

    assertThat(loader.getReloadCount()).isEqualTo(expectedReloads);

    // refresh 0
    ticker.advance(1, MILLISECONDS);
    assertThat(cache.getUnchecked(0)).isEqualTo(1);
    expectedReloads++;
    assertThat(cache.getUnchecked(1)).isEqualTo(1);
    assertThat(cache.getUnchecked(2)).isEqualTo(2);
    assertThat(loader.getLoadCount()).isEqualTo(expectedLoads);

    assertThat(network.edgeOrder()).isEqualTo(unordered());
    assertThat(network.nodeOrder()).isEqualTo(insertion()); // default
  }

  @Test
  public void edgeOrder_insertion() {
    MutableNetwork<Integer, String> network =
        NetworkBuilder.directed().edgeOrder(insertion()).build();

    addEdges(network);

    assertThat(network.edgeOrder()).isEqualTo(ElementOrder.insertion());

import assertk.assertThat
import assertk.assertions.isEqualTo
import okhttp3.Headers.Companion.headersOf
import org.junit.jupiter.api.Test

class WebSocketExtensionsTest {
  @Test
  fun emptyHeader() {
    assertThat(parse("")).isEqualTo(WebSocketExtensions())
  }

  @Test
  fun noExtensionHeader() {
    assertThat(WebSocketExtensions.parse(headersOf()))
      .isEqualTo(WebSocketExtensions())
  }

  @Test

    assertThat(HostAndPort.fromString(":102").toString()).isEqualTo(":102");
    assertThat(HostAndPort.fromParts("1::2", 103).toString()).isEqualTo("[1::2]:103");
    assertThat(HostAndPort.fromString("[::1]:104").toString()).isEqualTo("[::1]:104");

    // Without ports.
    assertThat(HostAndPort.fromString("foo").toString()).isEqualTo("foo");

            .build()
        }.build()

    val response = client.newCall(Request("https://google.com/robots.txt".toHttpUrl())).execute()

    assertThat(response.header("Content-Encoding")).isEqualTo("piedpiper")
    assertThat(response.body.string()).isEqualTo("Hello")
  }

  @Test
  fun gzipThroughCall() {
    val gzip = CompressionInterceptor(Gzip)
    val client =
      clientTestRule
        .newClientBuilder()

    assertThat(HostAndPort.fromString(":102").toString()).isEqualTo(":102");
    assertThat(HostAndPort.fromParts("1::2", 103).toString()).isEqualTo("[1::2]:103");
    assertThat(HostAndPort.fromString("[::1]:104").toString()).isEqualTo("[::1]:104");

    // Without ports.
    assertThat(HostAndPort.fromString("foo").toString()).isEqualTo("foo");

    String expectedToString = "cdab0000";

    assertEquals(expectedInt, hashCode.asInt());
    assertThat(hashCode.toString()).isEqualTo(expectedToString);

    bytes[0] = (byte) 0x00;

    assertEquals(expectedInt, hashCode.asInt());
    assertThat(hashCode.toString()).isEqualTo(expectedToString);
  }

  public void testFromBytesNoCopy_noCopyOccurs() {

    assertThat(f.get()).isEqualTo(CustomRuntimeException.class);
  }

  public void testCatchingAsync() throws Exception {
    FluentFuture<?> f =
        FluentFuture.from(immediateFailedFuture(new CustomRuntimeException()))
            .catchingAsync(Throwable.class, t -> immediateFuture(t.getClass()), directExecutor());
    assertThat(f.get()).isEqualTo(CustomRuntimeException.class);
  }

          // mess with cipher suite
          it.replace("TLS_", "SLT_")
        }
      }

    assertThat(response.body.string()).isEqualTo("ABC.1") // cached
    assertThat(cache.requestCount()).isEqualTo(2)
    assertThat(cache.networkCount()).isEqualTo(1)
    assertThat(cache.hitCount()).isEqualTo(1)

    assertThat(response.handshake!!.cipherSuite.javaName).startsWith("SLT_")
  }

  @Test
  fun truncatedMetadataEntry() {