new ByteSource() {
          @Override
          public InputStream openStream() throws IOException {
            if (counter[0]++ != 0) {
              throw new IllegalStateException("More than one source open");
            }
            return new FilterInputStream(source.openStream()) {
              @Override
              public void close() throws IOException {
                super.close();
                counter[0]--;

   */
  static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future)
      throws ExecutionException {
    checkState(future.isDone(), "Future was expected to be done: %s", future);
    try {
      return getUninterruptibly(future, 0, SECONDS);
    } catch (TimeoutException e) {
      throw new AssertionError(e);
    }
  }

  private TestPlatform() {}

     * @return The result of the project building, never {@code null}.
     * @throws ProjectBuildingException If the project descriptor could not be successfully built.
     */
    ProjectBuildingResult build(File projectFile, ProjectBuildingRequest request) throws ProjectBuildingException;

    /**
     * Builds a project descriptor for the specified artifact.
     *

  public void testOnlyOneOpen() throws Exception {
    String testString = "abcdefgh";
    CharSource source = newCharSource(testString);
    int[] counter = new int[1];
    CharSource reader =
        new CharSource() {
          @Override
          public Reader openStream() throws IOException {
            if (counter[0]++ != 0) {
              throw new IllegalStateException("More than one source open");

        assertTrue(bytesWritten > 68); // Should be larger due to scope
    }

    @Test
    @DisplayName("readTrailerWireFormat should read complete packet data")
    void testReadTrailerWireFormatSuccess() throws IOException {
        SessionRequestPacket writePacket =
                new SessionRequestPacket(mockConfig, new TestNetbiosName("SERVER", 0x20, null), new TestNetbiosName("CLIENT", 0x00, null));

      if (!response.isSuccessful) throw IOException("Unexpected code $response")
      println(response.body.string())
    }
  }

  private class ProgressRequestBody(
    private val delegate: RequestBody,
    private val progressListener: ProgressListener,
  ) : RequestBody() {
    override fun contentType() = delegate.contentType()

    @Throws(IOException::class)

     * This method extracts the host from the URL and enforces a delay based on the configured
     * delayMillisBeforeProcessing parameter.
     *
     * @throws InterruptedRuntimeException if the thread is interrupted during the delay
     * @throws CrawlerSystemException if an error occurs while processing the URL
     */
    @Override
    protected void delayBeforeProcessing() {

        @Test
        @DisplayName("toString with null challenge throws NPE")
        void testToStringWithNullChallengeThrowsNPE() {
            UniAddress dc = mock(UniAddress.class);
            when(dc.toString()).thenReturn("ANYSERVER");

            NtlmChallenge nc = new NtlmChallenge(null, dc);

            // Hexdump.toHexString will throw NPE when accessing challenge.length

                bindWithNullBinding.encode_in(mockBuffer);
            }, "Should throw NullPointerException when binding is null");
        }

        @Test
        @DisplayName("encode_in should use default constructor values")
        void testEncodeInDefaultConstructor() throws Exception {
            // Given
            DcerpcBind defaultBind = new DcerpcBind();

        .build();

    try (Response response = client.newCall(request).execute()) {
      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

      System.out.println(response.body().string());
    }
  }

  public static void main(String... args) throws Exception {
    new PostForm().run();
  }