}

    @Test
    @DisplayName("writeBytesWireFormat should write correct structure")
    void testWriteBytesWireFormat() {
        byte[] buffer = new byte[256];
        int offset = 64; // Start at offset to test proper indexing

        int written = request.writeBytesWireFormat(buffer, offset);

        // Verify bytes written
        assertEquals(24, written);

- **Network & I/O** (`org.codelibs.core.net`, `org.codelibs.core.nio`) - URL utilities, UUID generation, MIME type detection, and NIO channel operations

## 🚀 Getting Started

### Requirements
- **Java 21 or higher** (Required for modern language features)
- **Maven 3.6+** or **Gradle 7+** for build management
- **Optional**: SLF4J or Commons Logging for logging support

                        .filter(QueryBuilders.termsQuery(OpenSearchAccessResult.SESSION_ID, sessionIdList))
                        .filter(QueryBuilders.termQuery(OpenSearchAccessResult.STATUS, org.codelibs.fess.crawler.Constants.OK_STATUS));
                builder.setQuery(queryBuilder);
                builder.setFrom(0);

            byte[] buffer = new byte[100];
            TestCreateContextResponse response = new TestCreateContextResponse("BOUNDARY".getBytes(StandardCharsets.UTF_8));

            // Test at buffer start
            int result1 = response.decode(buffer, 0, 10);
            assertEquals(10, result1);

            // Test at buffer end
            int result2 = response.decode(buffer, 90, 10);

    // Check that we wait long enough anyway (presumably as long as MAX_VALUE nanos):
    TimedWaiterThread waiter = new TimedWaiterThread(future, Long.MAX_VALUE, SECONDS);
    waiter.start();
    waiter.awaitWaiting();

    future.set(1);
    waiter.join();
  }

  @J2ktIncompatible // TODO(b/324550390): Enable
  public void testSetNull() throws Exception {
    future.set(null);

    @DisplayName("Basic getters: address, hostName, inflight, sessions")
    void basicGetters() {
        assertEquals(address, transport.getRemoteAddress());
        assertNull(transport.getRemoteHostName(), "tconHostName starts null");
        assertEquals(0, transport.getInflightRequests());
        assertEquals(0, transport.getNumSessions());
    }

    @Test
    @DisplayName("isDisconnected / isFailed reflect socket and state")

                    return name.length();
                }

                @Override
                public CharSequence subSequence(final int start, final int end) {
                    return name.subSequence(start, end);
                }

            };
        }

        /**
         * @return CharSequence
         */
        public static CharSequence aaa() {

        var value = value
        // Write the raw value for a single byte value.
        if (value < prefixMask) {
          out.writeByte(bits or value)
          return
        }

        // Write the mask to start a multibyte value.
        out.writeByte(bits or prefixMask)
        value -= prefixMask

        // Write 7 bits at a time 'til we're done.
        while (value >= 0x80) {
          val b = value and 0x7f

        DirectoryCacheEntry cacheEntry = new DirectoryCacheEntry(directoryPath, leaseKey, scope);
        directoryCache.put(directoryPath, cacheEntry);
        leaseToPath.put(leaseKey, directoryPath);

        // Start change notification if enabled
        Configuration config = context.getConfig();
        if (isDirectoryNotificationsEnabled(config)) {
            changeNotifier.startWatching(directoryPath, leaseKey);
        }

                byte[] threadFileId = new byte[16];
                Arrays.fill(threadFileId, (byte) index);
                request.setFileId(threadFileId);
            });
            threads[i].start();
        }

        // Wait for all threads to complete
        for (Thread thread : threads) {
            thread.join();
        }

        // Then - should complete without errors