List<Range<C>> asRanges = ImmutableList.copyOf(rangeSet.asRanges());

    // test that connected ranges are coalesced
    for (int i = 0; i + 1 < asRanges.size(); i++) {
      Range<C> range1 = asRanges.get(i);
      Range<C> range2 = asRanges.get(i + 1);
      assertFalse(range1.isConnected(range2));
    }

    // test that there are no empty ranges
    for (Range<C> range : asRanges) {

                ftpClient.disconnect();
            } catch (final IOException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to disconnect FTP client: connected={}", ftpClient.isConnected(), e);
                }
            }
        }
        if (logger.isDebugEnabled()) {
            logger.debug("FTP client closed");
        }
    }

    /*
     * (non-Javadoc)

         *
         * @throws IOException If the connection cannot be established
         */
        @Override
        public synchronized void connect() throws IOException {
            if (connected) {
                return;
            }
            final String projectId = System.getenv("GCS_PROJECT_ID");
            final String endpoint = System.getenv("GCS_ENDPOINT");

         *
         * @throws IOException If the connection cannot be established
         */
        @Override
        public synchronized void connect() throws IOException {
            if (connected) {
                return;
            }
            final String endpoint = System.getenv().get("S3_ENDPOINT");
            final String accessKey = System.getenv().get("S3_ACCESS_KEY");

         *
         * @throws IOException If the connection cannot be established
         */
        @Override
        public synchronized void connect() throws IOException {
            if (connected) {
                return;
            }
            final String endpoint = System.getenv().get("STORAGE_ENDPOINT");
            final String accessKey = System.getenv().get("STORAGE_ACCESS_KEY");

      if (!success) {
        rawSocket?.closeQuietly()
      }
    }
  }

  override fun connectTlsEtc(): ConnectResult {
    val rawSocket = requireNotNull(rawSocket) { "TCP not connected" }
    check(!isReady) { "already connected" }

    val connectionSpecs = route.address.connectionSpecs
    var retryTlsConnection: ConnectPlan? = null
    var success = false

          RangeMap<Integer, Integer> expected = TreeRangeMap.create();
          for (Entry<Range<Integer>, Integer> entry : rangeMap.asMapOfRanges().entrySet()) {
            if (entry.getKey().isConnected(subRange)) {
              expected.put(entry.getKey().intersection(subRange), entry.getValue());
            }
          }
          RangeMap<Integer, Integer> subRangeMap = rangeMap.subRangeMap(subRange);

        onConnectListenerList.add(listener);
    }

    /**
     * Checks if the client is connected to OpenSearch.
     *
     * @return true if connected, false otherwise.
     */
    public boolean connected() {
        return connected;
    }

    /**
     * Connects to the OpenSearch cluster.

        String objectName = (String) getField(conn, "objectName");
        assertEquals("/path//to//object.txt", objectName);
    }

    /**
     * Test that getInputStream() attempts to connect if not connected.
     */
    public void test_getInputStream_autoConnect() throws Exception {
        URL url = new URL("gcs://mybucket/object.txt");
        Handler handler = new Handler();

        connectTcpNextPlan != null -> {
          events += "plan $id needs follow-up"
          ConnectResult(this, nextPlan = connectTcpNextPlan)
        }
        else -> {
          events += "plan $id TCP connected"
          connectState = ConnectState.TCP_CONNECTED
          ConnectResult(this)
        }
      }
    }

    override fun connectTlsEtc(): ConnectResult {