void testMultipleCloseOnManagedResource() throws Exception {
        TestResource resource = new TestResource("multiclose");
        ResourceManager.ManagedResource<TestResource> managed = resourceManager.manage(resource);

        managed.close();
        assertTrue(resource.isClosed());

        // Second close should not throw
        assertDoesNotThrow(managed::close);
    }

    @Test

        /**
         * Accepts a writer.
         * @param writer A writer.
         * @throws IOException if an I/O error occurs.
         * @throws TikaException if a Tika exception occurs.
         * @throws SAXException if a SAX exception occurs.
         */
        void accept(Writer writer) throws IOException, TikaException, SAXException;
    }

    /**
     * Sets the output encoding.

      }
    }
  }

  @Test
  @Throws(Exception::class)
  fun compressedMessages() {
    successfulExtensions("permessage-deflate")
  }

  @Test
  @Throws(Exception::class)
  fun compressedMessagesNoClientContextTakeover() {
    successfulExtensions("permessage-deflate; client_no_context_takeover")
  }

  @Test
  @Throws(Exception::class)

     *
     * @param url An smb URL string representing the file to write to
     * @throws SmbException if an SMB error occurs
     * @throws MalformedURLException if the URL is not properly formatted
     * @throws UnknownHostException if the host cannot be resolved
     */

    public SmbFileOutputStream(final String url) throws SmbException, MalformedURLException, UnknownHostException {
        this(url, false);
    }

     * @param smbFile the SmbFile directory to list
     * @return array of SmbFile objects representing the directory contents
     * @throws SmbException if an error occurs
     */
    public static SmbFile[] listFilesWithLeasing(SmbFile smbFile) throws SmbException {
        if (!smbFile.isDirectory()) {
            throw new SmbException("Not a directory: " + smbFile.getPath());
        }

        });

        assertEquals("Missing AvEOL", exception.getMessage(), "Should throw exception for truncated data");
    }

    /**
     * Test decode with unknown AvPair type
     */
    @Test
    @DisplayName("Decode unknown AvPair type as generic AvPair")
    void testDecodeUnknownType() throws CIFSException {
        byte[] data = new byte[] { 0x01, 0x02, 0x03, 0x04 };
        int unknownType = 0xFF;

    }

    private void parse(final byte[] material) throws IOException {
        int pos = 0;
        for (int i = 0; i < 8; i++) {
            if (material[i] != NTLMSSP_SIGNATURE[i]) {
                throw new IOException("Not an NTLMSSP message.");
            }
        }
        pos += 8;

        if (readULong(material, pos) != NTLMSSP_TYPE1) {
            throw new IOException("Not a Type 1 message.");
        }

        assertEquals(pathBytes.length, SMBUtil.readInt2(buffer, Smb2Constants.SMB2_HEADER_LENGTH + 6));
    }

    @Test
    @DisplayName("Should throw exception when buffer too small for path")
    void testBufferTooSmallForPath() throws Exception {
        // Given
        String longPath = "\\\\server\\very_long_share_name_that_exceeds_buffer";

    @Test
    void testInitializationWithoutMultiChannelSupport() throws IOException {
        when(mockConfig.isUseMultiChannel()).thenReturn(false);
        ChannelManager manager = new ChannelManager(mockContext, mockSession);

        manager.initializeMultiChannel();

        assertFalse(manager.isUseMultiChannel());
    }

    @Test
    void testGetHealthyChannels() throws UnknownHostException {

  public void readFully(byte[] b, int off, int len) throws IOException {
    ByteStreams.readFully(this, b, off, len);
  }

  @Override
  public int skipBytes(int n) throws IOException {
    return (int) in.skip(n);
  }

  @CanIgnoreReturnValue // to skip a byte
  @Override
  public int readUnsignedByte() throws IOException {
    int b1 = in.read();
    if (b1 < 0) {
      throw new EOFException();
    }

    return b1;