URL url = new URL(null, "smb://example-host/share/", new Handler());

        // Act
        URLConnection conn = handler.openConnection(url);

        // Assert
        assertNotNull(conn);
        assertTrue(conn instanceof SmbFile, "Connection should be an instance of SmbFile");
        SmbFile file = (SmbFile) conn;
        assertEquals(url, file.getURL(), "Returned SmbFile should wrap the given URL");

        for (final SmbTransportImpl conn : this.connections) {
            if (conn.matches(address, port, localAddr, localPort, hostName)
                    && (tc.getConfig().getSessionLimit() == 0 || conn.getNumSessions() < tc.getConfig().getSessionLimit())) {
                try {
                    if (conn.isFailed() || connectedOnly && conn.isDisconnected()) {
                        continue;

    path: String,
    responseCode: AtomicInteger,
  ): Thread =
    Thread {
      val url = mockWebServer.url(path).toUrl()
      val conn: HttpURLConnection
      try {
        conn = url.openConnection() as HttpURLConnection
        responseCode.set(conn.responseCode) // Force the connection to hit the "server".
      } catch (ignored: IOException) {
      }
    }

     *
     * @param conn
     *            {@link JarURLConnection}. Must not be {@literal null}.
     * @return {@link JarFile}
     */
    public static JarFile getJarFile(final JarURLConnection conn) {
        assertArgumentNotNull("conn", conn);

        try {
            return conn.getJarFile();
        } catch (final IOException e) {

 *
 */
class SmbTreeConnectionTrace extends SmbTreeConnection {

    SmbTreeConnectionTrace(final CIFSContext ctx) {
        super(ctx);
    }

    SmbTreeConnectionTrace(final SmbTreeConnection conn) {
        super(conn);
    }

    @Override
    protected void finalize() throws Throwable {
        checkRelease();
    }

        // Arrange - Create URL with handler
        URL url = new URL(null, "smb://host/share", handler);

        // Act
        URLConnection conn = handler.openConnection(url);

        // Assert
        assertNotNull(conn);
        assertTrue(conn instanceof SmbFile);
    }

    @Test
    @DisplayName("openConnection throws NPE for null URL")
    void testOpenConnectionWithNullUrl() {
        // Act & Assert

     */
    private void mockResponse(HttpURLConnection conn, int code, String message, Map<String, List<String>> headers, InputStream stream)
            throws IOException {
        if (conn == null)
            return;

        String statusLine = "HTTP/1.1 " + code + " " + message;
        when(conn.getResponseCode()).thenReturn(code);
        when(conn.getResponseMessage()).thenReturn(message);

                        return conn;
                    }
                }
            }

            conn = new SmbTransport(address, port, localAddr, localPort);
            CONNECTIONS.add(0, conn);
        }

        return conn;
    }

    class ServerData {
        byte flags;
        int flags2;
        int maxMpxCount;
        int maxBufferSize;

        CurlRequest request = new CurlRequest(Method.GET, "https://example.com");

        // Multiple onConnect calls should work (last one wins)
        request.onConnect((req, conn) -> conn.setConnectTimeout(1000));
        request.onConnect((req, conn) -> conn.setReadTimeout(2000));

        assertNotNull(request);
    }

    @Test
    public void testSslSocketFactoryWithNull() {

    req.start()
    return completableFuture
  }

  @Test
  fun urlConnection() {
    val conn = engine.openConnection(URL("https://google.com/robots.txt")) as HttpURLConnection

    val text =
      conn.inputStream.use {
        it.bufferedReader().readText()
      }

    assertEquals(200, conn.responseCode)

    assertTrue(text.contains("Disallow"))
  }