this.expectedContent.put(resourceName, expectedContent);
    }

    public String[] getSupportedProtocols() {
        return new String[] {"string"};
    }

    @Override
    public void closeConnection() throws ConnectionException {}

    @Override
    public void fillInputData(InputData inputData)
            throws TransferFailedException, ResourceDoesNotExistException, AuthorizationException {

	// proxy
	defer con.MarkInitialized()

	// Complete full initialization of the proxy
	if err := s.initializeProxy(con); err != nil {
		s.closeConnection(con)
		return err
	}
	return nil
}

func (s *DiscoveryServer) closeConnection(con *Connection) {
	if con.ID() == "" {
		return
	}
	s.removeCon(con.ID())
	if s.StatusReporter != nil {

java.text.DateFormat dateFormat; private CorrectedWebdavResou webdavResource; public void WebDavWagon(); public void openConnection() throws org.apache.maven.wagon.authentication.AuthenticationExcept, org.apache.maven.wagon.ConnectionException; public void closeConnection() throws org.apache.maven.wagon.ConnectionException; public void put(java.io.File, String) throws org.apache.maven.wagon.TransferFailedExcept, org.apache.maven.wagon.ResourceDoesNotExist, org.apache.maven.wagon.authorization.AuthorizationExcepti;...

TransferFailedExcept, ResourceDoesNotExist; public abstract void fillOutputData(OutputData) throws TransferFailedExcept; public abstract void openConnection() throws ConnectionException, authentication.AuthenticationExcept; public abstract void closeConnection() throws ConnectionException; public void get(String, java.io.File) throws TransferFailedExcept, ResourceDoesNotExist, authorization.AuthorizationExcepti; public boolean getIfNewer(String, java.io.File, long) throws TransferFailedExcept, ResourceDoesNotExist,...

TransferFailedExcept, ResourceDoesNotExist; public abstract void fillOutputData(OutputData) throws TransferFailedExcept; public abstract void openConnection() throws ConnectionException, authentication.AuthenticationExcept; public abstract void closeConnection() throws ConnectionException; public void get(String, java.io.File) throws TransferFailedExcept, ResourceDoesNotExist, authorization.AuthorizationExcepti; public boolean getIfNewer(String, java.io.File, long) throws TransferFailedExcept, ResourceDoesNotExist,...

				return
			}
			if err := s.initConnection(req.Node, con, identities); err != nil {
				con.ErrorCh() <- err
				return
			}
			defer s.closeConnection(con)
			deltaLog.Infof("ADS: new delta connection for node:%s", con.ID())
		}

		select {
		case con.deltaReqChan <- req:
		case <-con.deltaStream.Context().Done():

    assertThat(pool.closeConnections(50L)).isEqualTo(100L)
    assertThat(pool.connectionCount()).isEqualTo(1)
    assertThat(c1.socket().isClosed).isFalse()

    // Running at time 60, the pool returns that nothing can be evicted until time 150.
    assertThat(pool.closeConnections(60L)).isEqualTo(90L)
    assertThat(pool.connectionCount()).isEqualTo(1)

  private val cleanupQueue: TaskQueue = taskRunner.newQueue()
  private val cleanupTask =
    object : Task("$okHttpName ConnectionPool connection closer") {
      override fun runOnce(): Long = closeConnections(System.nanoTime())
    }

  private fun AddressState.scheduleOpener() {
    queue.schedule(
      object : Task("$okHttpName ConnectionPool connection opener") {