queue = (BlockingQueue<String>) constructor.newInstance(capacity);

    strings = new String[capacity];
    for (int i = 0; i < capacity; i++) {
      strings[i] = String.valueOf(Math.random());
    }
  }

  @Benchmark
  void addsAndRemoves(int reps) {
    int capacity = this.capacity;
    BlockingQueue<String> queue = this.queue;
    String[] strings = this.strings;

    val SYSTEM: Dns = DnsSystem()

    private class DnsSystem : Dns {
      override fun lookup(hostname: String): List<InetAddress> {
        try {
          return InetAddress.getAllByName(hostname).toList()
        } catch (e: NullPointerException) {
          throw UnknownHostException("Broken system behaviour for dns lookup of $hostname").apply {
            initCause(e)
          }
        }
      }
    }
  }

      while (itr.hasNext()) {
        expectedSpan = expectedSpan.span(itr.next());
      }
    }

    try {
      Range<C> span = rangeSet.span();
      assertEquals(expectedSpan, span);
    } catch (NoSuchElementException e) {
      assertNull(expectedSpan);
    }

    // test that asDescendingSetOfRanges is the reverse of asRanges

  @Override
  public SampleElements<Entry<String, String>> samples() {
    return new SampleElements<>(
        mapEntry("one", "January"),
        mapEntry("two", "February"),
        mapEntry("three", "March"),
        mapEntry("four", "April"),
        mapEntry("five", "May"));
  }

  @Override
  public Map<String, String> create(Object... entries) {
    @SuppressWarnings("unchecked")

        if (jdk.startsWith("[") || jdk.startsWith("(")) {
            try {
                return matchJdkVersionRange(jdk);
            } catch (InvalidVersionSpecificationException e) {
                throw new ProfileActivationException(
                        "Invalid JDK version in profile '" + profile.getId() + "': " + e.getMessage());
            }
        }

     */
    @Test
    public void testModularOption() {
        String[] formatted = JavaPathType.patchModule("my.module").option(paths());
        assertEquals(2, formatted.length);
        assertEquals("--patch-module", formatted[0]);
        assertEquals(toPlatformSpecific("my.module=\"src/foo.java:src/bar.java\""), formatted[1]);
    }

                    sink.writeUtf8(".")
                    sink.flush()
                    Thread.sleep(100)
                  }
                } catch (e: IOException) {
                  log.add(e.toString())
                  throw e
                } catch (e: Exception) {
                  log.add(e.toString())
                }
              }
            },
          ).build(),
      )

          ByteStreams.exhaust(decodingStream);
          fail("Expected DecodingException");
        } catch (DecodingException expected) {
          // Don't assert on the expectedMessage; the messages for exceptions thrown from the
          // decoding stream may differ from the messages for the decode methods.
        } catch (IOException e) {
          fail("Expected DecodingException but got: " + e);
        }
      }
    };

        copySettings();
    }

    /**
     *
     */
    private final void copySettings() {
        try {
            this.setRequestMethod(this.connection.getRequestMethod());
        } catch (final ProtocolException e) {
            throw new RuntimeCIFSException("Failed to set request method", e);
        }
        this.headerFields = null;

    public void setUp() throws Exception {
        super.setUp();
        fileTypeHelper = new FileTypeHelper();
    }

    public void test_init() {
        try {
            fileTypeHelper.init();
        } catch (Exception e) {
            fail("init() should not throw an exception: " + e.getMessage());
        }
    }

    public void test_add() {
        fileTypeHelper.add("application/pdf", "pdf");