- **Thread Safety**: Components support concurrent access
- **DFS Support**: Distributed File System resolution
- **Streaming Operations**: Efficient directory listings and file operations
- **Buffer Caching**: Optimized buffer management
- **DCE/RPC Protocol**: Support for advanced operations

## Quick Start

### Basic Usage

```java
import jcifs.CIFSContext;
import jcifs.context.SingletonContext;

    def mainApiChangesJsonFile = apiChangesJsonDirectory.file("accepted-public-api-changes.json")

    def acceptedViolationsFiles = apiChangesJsonDirectory.asFileTree.matching {
        include("**/*.json")
    }

    def isSnapshot = gradleModule.identity.snapshot
    inputs.files(acceptedViolationsFiles)
    inputs.property("baseline.version", compatibilityBaselineVersion)

                writeText(readText().replace("\\Q<lastUpdated>\\E\\d+\\Q</lastUpdated>\\E".toRegex(), "<lastUpdated>${Year.now().value}0101000000</lastUpdated>"))
            }
            localRepository.get().asFileTree.matching { include("**/*.module") }.forEach {
                val content = it.readText()
                    .replace("\"buildId\":\\s+\"\\w+\"".toRegex(), "\"buildId\": \"\"")

`TikaExtractor`, `PdfExtractor`, `MsWordExtractor`, `MsExcelExtractor`, `MsPowerPointExtractor`, `ZipExtractor`, `HtmlExtractor`, `MarkdownExtractor`, `EmlExtractor`

### Helpers

- **RobotsTxtHelper**: RFC 9309 parsing, user-agent matching, crawl-delay, sitemaps
- **SitemapsHelper**: Sitemap XML parsing, index handling
- **MimeTypeHelper**: MIME detection via Tika
- **EncodingHelper**: Charset detection with BOM
- **UrlConvertHelper**: URL normalization

 * It is recommended (but not required) to also explicitly declare which core specs your project depends on to help optimize the caching
 * behavior.
 * <i>For example:</i>
 * <pre>
 * restResources {
 *   restApi {
 *     includeCore 'index', 'cat'
 *     includeXpack 'enrich'
 *   }
 * }
 * </pre>
 * <br>

        assertEquals(0, result);
    }

    @Test
    void testReadDataWireFormatAtBufferBoundary() throws SMBProtocolDecodingException {
        // Test with data length exactly matching outputBuffer size
        byte[] testData = new byte[outputBuffer.length];
        Arrays.fill(testData, (byte) 0xFF);
        byte[] buffer = new byte[outputBuffer.length + 100];

from typing import Annotated, Any

from annotated_doc import Doc
from pydantic import AfterValidator, BaseModel, Field, model_validator
from starlette.responses import StreamingResponse

# Canonical SSE event schema matching the OpenAPI 3.2 spec
# (Section 4.14.4 "Special Considerations for Server-Sent Events")
_SSE_EVENT_SCHEMA: dict[str, Any] = {
    "type": "object",
    "properties": {
        "data": {"type": "string"},

		}
	})

	t.Run("if-match with read quorum failure", func(t *testing.T) {
		// Test Case 2: if-match (update only if ETag matches)
		// With if-match: <etag>, this should only succeed if object exists with matching ETag.
		// Since read quorum fails, we can't determine if object exists or ETag matches.
		opts := ObjectOptions{
			UserDefined: map[string]string{
				xhttp.IfMatch: existingETag,
			},

                tree = getProject().fileTree(dir);
            } else {
                tree = tree.plus(getProject().fileTree(dir));
            }
        }
        return tree == null ? null : tree.matching(patternFilterable -> patternFilterable.include("**/*-NOTICE.txt"));
    }

    @InputFiles
    @Optional
    public FileCollection getSources() {
        return sources;
    }

    }

    /**
     * Adds a bad word.
     *
     * @param index The index name
     * @param badWord The bad word to add
     * @param apply Whether to apply the change immediately (delete matching items)
     * @return The SuggestDeleteResponse
     */
    public SuggestDeleteResponse addBadWord(final String index, final String badWord, final boolean apply) {