if (hasErrors) {
      return
    }
    try {
      super.flush()
    } catch (e: IOException) {
      hasErrors = true
      onException(e)
    }
  }

  override fun close() {
    try {
      super.close()
    } catch (e: IOException) {
      hasErrors = true
      onException(e)
    }
  }

        }
    }

    @Override
    public void close() {
        // GCS Storage client doesn't require explicit close
        // but we can try to close it if needed
        try {
            storage.close();
        } catch (final Exception e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Failed to close GCS storage client", e);
            }
        }
    }

        SmbFile targetFile = new SmbFile(baseUrl + "shared/" + targetFileName, renameContext);

        // Copy content to new file
        srcForCopy.copyTo(targetFile);
        srcForCopy.close();
        targetFile.close();

        // Wait before delete
        Thread.sleep(500);
        System.gc();
        Thread.sleep(200);

        // Delete original using fresh context

                  }
                },
              ).build()
          }
        }
      if ("close".equals(response.request.header("Connection"), ignoreCase = true) ||
        "close".equals(response.header("Connection"), ignoreCase = true)
      ) {
        exchange.noNewExchangesOnConnection()
      }

    StringWriter writer = new StringWriter();
    char[] buf = new char[64];
    int read;
    while ((read = reader.read(buf)) != -1) {
      writer.write(buf, 0, read);
    }
    reader.close();
    writer.close();

    assertExpectedString(writer.toString());
  }

  public void testOpenBufferedStream() throws IOException {
    BufferedReader reader = source.openBufferedStream();

        return this.open && this.tree_num == this.tree.getTreeId() && this.tree.isConnected();
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.SmbFileHandle#close(long)
     */
    @Override
    public synchronized void close(final long lastWriteTime) throws CIFSException {
        closeInternal(lastWriteTime, true);
    }

    /**
     * @param lastWriteTime
     * @throws SmbException
     */

        // Close and verify subsequent calls throw
        handle.close();
        CIFSException ex1 = assertThrows(CIFSException.class, handle::getInput, "getInput after close must throw");
        assertTrue(ex1.getMessage().contains("Already closed"));
        CIFSException ex2 = assertThrows(CIFSException.class, handle::getOutput, "getOutput after close must throw");

        // Act
        raf.close();

        // Assert interactions
        verify(handle, atLeastOnce()).close();
        verify(file, times(1)).clearAttributeCache();
        verify(file, never()).close();
    }

    @Test
    @DisplayName("close(): closes SmbFile when unsharedFile=true")
    void close_unsharedFile_closesFile() throws Exception {

  }

  private final class Out extends TestOutputStream {

    Out() throws IOException {
      super(bytes, options);
    }

    @Override
    public void close() throws IOException {
      outputStreamClosed = true;
      super.close();
    }
  }

    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.SmbTransportPool#close()
     */
    @Override
    public boolean close() throws CIFSException {
        boolean inUse = false;

        // Cleanup first
        cleanup();
        log.debug("Closing pool");

        // Create a snapshot of connections to close
        List<SmbTransportImpl> toClose = new ArrayList<>(this.connections);