- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Awaitable (0.42 sec)
-
fastapi/datastructures.py
Any next read or write will be done from that position. To be awaitable, compatible with async, this is run in threadpool. """ return await super().seek(offset) async def close(self) -> None: """ Close the file. To be awaitable, compatible with async, this is run in threadpool. """ return await super().close()Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 12:54:56 UTC 2025 - 5.1K bytes - Viewed (0) -
tests/test_dependency_contextvars.py
from collections.abc import Awaitable from contextvars import ContextVar from typing import Any, Callable, Optional from fastapi import Depends, FastAPI, Request, Response from fastapi.testclient import TestClient legacy_request_state_context_var: ContextVar[Optional[dict[str, Any]]] = ContextVar( "legacy_request_state_context_var", default=None ) app = FastAPI() async def set_up_request_state_dependency():
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 21:25:59 UTC 2025 - 1.5K bytes - Viewed (0) -
fastapi/routing.py
# dependencies' AsyncExitStack def request_response( func: Callable[[Request], Union[Awaitable[Response], Response]], ) -> ASGIApp: """ Takes a function or coroutine `func(request) -> response`, and returns an ASGI application. """ f: Callable[[Request], Awaitable[Response]] = ( func if is_async_callable(func) else functools.partial(run_in_threadpool, func) # type:ignore )
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 12:54:56 UTC 2025 - 174.6K bytes - Viewed (0) -
fastapi/applications.py
```python import time from typing import Awaitable, Callable from fastapi import FastAPI, Request, Response app = FastAPI() @app.middleware("http") async def add_process_time_header( request: Request, call_next: Callable[[Request], Awaitable[Response]] ) -> Response: start_time = time.time()Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 21:25:59 UTC 2025 - 176.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/exception/CrawlerSystemExceptionTest.java
// Test with suppression enabled and writable stack trace String message1 = "Test with suppression enabled"; CrawlerSystemException exception1 = constructor.newInstance(message1, true, true); assertNotNull(exception1); assertEquals(message1, exception1.getMessage()); assertNull(exception1.getCause()); // Test with suppression disabled and writable stack traceRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Wed Sep 03 14:42:53 UTC 2025 - 20K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/exception/CrawlerSystemException.java
* It also provides a protected constructor that allows to specify whether or not suppression is enabled or stack trace is writable. */ public class CrawlerSystemException extends RuntimeException { private static final long serialVersionUID = 1L; /**Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/beans/impl/PropertyDescImpl.java
if (field != null && ModifierUtil.isPublic(field)) { readable = true; writable = true; } } @Override public boolean isReadable() { return readable; } @Override public boolean isWritable() { return writable; } @Override public <T> T getValue(final Object target) {
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Thu Jul 24 01:52:43 UTC 2025 - 15.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exception/FessSystemException.java
* * @param message the detail message describing the exception * @param enableSuppression whether suppression is enabled or disabled * @param writableStackTrace whether the stack trace should be writable */ protected FessSystemException(final String message, final boolean enableSuppression, final boolean writableStackTrace) { super(message, null, enableSuppression, writableStackTrace); }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/user/allcommon/EsAbstractBehavior.java
import org.dbflute.Entity; import org.dbflute.bhv.AbstractBehaviorWritable; import org.dbflute.bhv.readable.EntityRowHandler; import org.dbflute.bhv.writable.DeleteOption; import org.dbflute.bhv.writable.InsertOption; import org.dbflute.bhv.writable.UpdateOption; import org.dbflute.cbean.ConditionBean; import org.dbflute.cbean.coption.CursorSelectOption; import org.dbflute.cbean.result.ListResultBean;
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 27 07:01:25 UTC 2025 - 26.4K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbFileIntegrationTest.java
// Test setting attributes file.setReadOnly(); assertFalse(file.canWrite(), "Should not be writable when read-only"); file.setReadWrite(); assertTrue(file.canWrite(), "Should be writable after setReadWrite"); } @Test void testFileOverwriteWithDifferentContent() throws Exception { long timestamp = System.currentTimeMillis();Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 56K bytes - Viewed (0)