Anis Eleuch <******@****.***> 1726173845 +0100

Klaus Post <******@****.***> 1756435188 +0200

Mark Theunissen <******@****.***> 1723562716 +1000

Mark Theunissen <******@****.***> 1723963383 +1000

If an incoming request does not validate correctly then a `400` response will be sent.

## `GZipMiddleware` { #gzipmiddleware }

Handles GZip responses for any request that includes `"gzip"` in the `Accept-Encoding` header.

The middleware will handle both standard and streaming responses.

{* ../../docs_src/advanced_middleware/tutorial003_py310.py hl[2,6] *}

The following arguments are supported:

    protected boolean allowGuestFallback = false;
    /** Whether to use durable handles for improved reliability */
    protected boolean useDurableHandles = true;
    /** Whether to use persistent handles for maximum reliability */
    protected boolean usePersistentHandles = false;
    /** Timeout for durable handles in milliseconds */
    protected long durableHandleTimeout = 120000; // 2 minutes

     */
    public static boolean canCacheEnumeration(int state) {
        return Smb2LeaseState.hasReadCaching(state);
    }

    /**
     * Check if directory can keep handles open
     * @param state lease state
     * @return true if directory handles can be kept open
     */
    public static boolean canKeepHandlesOpen(int state) {
        return Smb2LeaseState.hasHandleCaching(state);
    }

    /**

                docMeta.primaryTerm(hit.getPrimaryTerm());
                handler.handle(entity);
            });

            return !handler.isBreakCursor();
        });
    }

    protected <RESULT extends ENTITY> void delegateSelectBulk(final ConditionBean cb, final EntityRowHandler<List<RESULT>> handler,
            final Class<? extends RESULT> entityType) {
        assertCBStateValid(cb);

        """
        Run any `.on_startup` event handlers.

        This method is kept for backward compatibility after Starlette removed
        support for on_startup/on_shutdown handlers.

        Ref: https://github.com/Kludex/starlette/pull/3117
        """
        for handler in self.on_startup:
            if is_async_callable(handler):
                await handler()
            else:
                handler()

     * Test search with negative start position (should be handled gracefully).
     */
    @Test
    public void test_searchWithNegativeStartPosition() throws Exception {
        try (RankFusionProcessor processor = new RankFusionProcessor()) {
            processor.setSearcher(new TestSearcher(100));
            processor.init();

            // Implementation should handle this gracefully