assertEquals("B", peekingIterator.next());
    peekingIterator.remove();
    assertEquals("Should have removed an element", 2, list.size());
    assertFalse("Second element should be gone", list.contains("B"));
  }

  static class ThrowsAtEndException extends RuntimeException {
    /* nothing */
  }

  /**

    // Now we hit the cap
    assertEquals(1 << 30, ImmutableSet.chooseTableSize(1 << 29));
    assertEquals(1 << 30, ImmutableSet.chooseTableSize((1 << 30) - 1));

    // Now we've gone too far
    assertThrows(IllegalArgumentException.class, () -> ImmutableSet.chooseTableSize(1 << 30));
  }

  @GwtIncompatible // RegularImmutableSet.table not in emulation
  public void testResizeTable() {

    // Now we hit the cap
    assertEquals(1 << 30, ImmutableSet.chooseTableSize(1 << 29));
    assertEquals(1 << 30, ImmutableSet.chooseTableSize((1 << 30) - 1));

    // Now we've gone too far
    assertThrows(IllegalArgumentException.class, () -> ImmutableSet.chooseTableSize(1 << 30));
  }

  @GwtIncompatible // RegularImmutableSet.table not in emulation
  public void testResizeTable() {

            String readContent = new String(in.readAllBytes(), "UTF-8");
            assertEquals(content, readContent, "Content should be preserved after rename");
        }

        // Best effort to verify source is gone
        SmbFile checkSource = new SmbFile(baseUrl + "shared/" + sourceFileName, checkContext);
        if (checkSource.exists()) {
            log.warn("Source file still exists after rename, attempting cleanup");

- github.com/mitchellh/mapstructure: [v1.1.2](https://github.com/mitchellh/mapstructure/tree/v1.1.2)
- github.com/oklog/ulid: [v1.3.1](https://github.com/oklog/ulid/tree/v1.3.1)
- github.com/pascaldekloe/goe: [57f6aae](https://github.com/pascaldekloe/goe/tree/57f6aae)
- github.com/pelletier/go-toml: [v1.2.0](https://github.com/pelletier/go-toml/tree/v1.2.0)
- github.com/posener/complete: [v1.1.1](https://github.com/posener/complete/tree/v1.1.1)

    private val body: Sink
    var done = false

    init {
      this.body =
        object : ForwardingSink(cacheOut) {
          @Throws(IOException::class)
          override fun close() {
            synchronized(this@Cache) {
              if (done) return
              done = true
              writeSuccessCount++
            }
            super.close()

    assertSame(CharMatcher.any(), CharMatcher.none().negate());
    assertSame(CharMatcher.none(), CharMatcher.any().negate());

    assertSame(WHATEVER, CharMatcher.any().and(WHATEVER));
    assertSame(CharMatcher.any(), CharMatcher.any().or(WHATEVER));

    assertSame(CharMatcher.none(), CharMatcher.none().and(WHATEVER));
    assertSame(WHATEVER, CharMatcher.none().or(WHATEVER));
  }

        fun run() {
          val progressListener = object : ProgressListener {
            private var firstUpdate = true

            override fun update(bytesWritten: Long, contentLength: Long, done: Boolean) {
              if (done) {
                println("completed")
              } else {
                if (firstUpdate) {
                  firstUpdate = false
                  if (contentLength == -1L) {

    }

    @Test
    public void testHandleType() {
        assertEquals(0, HandleType.NONE.getValue());
        assertEquals(1, HandleType.DURABLE_V1.getValue());
        assertEquals(2, HandleType.DURABLE_V2.getValue());
        assertEquals(3, HandleType.PERSISTENT.getValue());

        assertEquals(HandleType.NONE, HandleType.fromValue(0));
        assertEquals(HandleType.DURABLE_V1, HandleType.fromValue(1));

    @Volatile private var queryParamsNameToRedact = emptySet<String>()

    @set:JvmName("level")
    @Volatile
    var level = Level.NONE

    enum class Level {
      /** No logs. */
      NONE,

      /**
       * Logs request and response lines.
       *
       * Example:
       * ```
       * --> POST /greeting http/1.1 (3-byte body)
       *