Exception thrownException = assertThrows(Exception.class, mockSession::close, "close() should propagate exceptions");
            assertEquals("Test close exception", thrownException.getMessage());
        }
    }

    @Nested
    @DisplayName("Configuration Access Tests")
    class ConfigurationAccessTest {

        @Test

            IllegalStateException exception = assertThrows(IllegalStateException.class, () -> {
                testRequest.encode(buffer, 0);
            });

            assertTrue(exception.getMessage().contains("Wrong size calculation"));
        }
    }

    // Test implementation classes
    private static class TestServerMessageBlock2Request extends ServerMessageBlock2Request<TestServerMessageBlock2Response> {

            System.out.println("Async suggestion: " + item.getText()[0])
        );
    })
    .error(throwable -> {
        // Handle error
        System.err.println("Error: " + throwable.getMessage());
    });
```

## Advanced Usage

### Index from Existing Documents

```java
import org.codelibs.fess.suggest.index.contents.document.ESSourceReader;

    }

    boolean hasCapability(final int cap) throws SmbException {
        try {
            connect(RESPONSE_TIMEOUT);
        } catch (final IOException ioe) {
            throw new SmbException(ioe.getMessage(), ioe);
        }
        return (capabilities & cap) == cap;
    }

    boolean isSignatureSetupRequired(final NtlmPasswordAuthentication auth) {

                        final List<Map<String, String>> langItems = new ArrayList<>(supportedLanguages.length);
                        final String msg = ComponentUtil.getMessageManager().getMessage(displayLocale, "labels.allLanguages");
                        final Map<String, String> defaultMap = new HashMap<>(2);
                        defaultMap.put(Constants.ITEM_LABEL, msg);

        try {
            executeThumbnailGenerator();
        } catch (final Exception e) {
            logger.warn("Failed to generate thumbnails.", e);
            resultBuf.append(e.getMessage()).append("\n");
        } finally {
            if (timeoutTask != null && !timeoutTask.isCanceled()) {
                timeoutTask.cancel();
            }
        }

        return resultBuf.toString();

            FileUtil.readBytes(largeFile);
            fail("Expected IORuntimeException for large file");
        } catch (final IORuntimeException e) {
            assertTrue("Error message should mention file size", e.getMessage().contains("File too large"));
        }
    }

    /**
     * Test readBytes with file within size limit
     *
     * @throws Exception
     */
    @Test

                        response.isReceived = true;
                        notifyAll();
                    }
                }
            } catch (final Exception ex) {
                final String msg = ex.getMessage();
                final boolean timeout = msg != null && msg.equals("Read timed out");
                /* If just a timeout, try to disconnect gracefully
                 */
                final boolean hard = !timeout;

                    }
                } else {
                    logger.warn("Failed to access Web API.", e);
                }
                message = e.getMessage();
            } else {
                final String errorCode = UUID.randomUUID().toString();
                message = "[" + errorCode + "] Failed to access to Web API.";

                writeSecurityBuffer(type2, 40, data + target.length, targetInformation);
            }
            return type2;
        } catch (final IOException ex) {
            throw new IllegalStateException(ex.getMessage());
        }
    }

    @Override
    public String toString() {
        final String target = getTarget();
        final byte[] challenge = getChallenge();
        final byte[] context = getContext();