- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 93 for unblocking (0.11 sec)
-
fastapi/datastructures.py
Define it as a *path operation function* (or dependency) parameter. If you are using a regular `def` function, you can use the `upload_file.file` attribute to access the raw standard Python file (blocking, not async), useful and needed for non-async code. Read more about it in the [FastAPI docs for Request Files](https://fastapi.tiangolo.com/tutorial/request-files/). ## Example ```python
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 5.6K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* Fix bug where the Content-Length header was not always dropped when following a redirect from a POST to a GET. * Implement basic support for `Thread.interrupt()`. OkHttp now checks for an interruption before doing a blocking call. If it is interrupted, it throws an `InterruptedIOException`. ## Version 1.5.2 _2014-03-17_ * Fix bug where deleting a file that was absent from the `HttpResponseCache` caused an IOException.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 6.4K bytes - Viewed (0) -
RELEASE_BRANCHES.md
merged in before and after the first public release. # Feature Freeze One week before a release, the release branch goes into a state of code freeze. At this point only critical release blocking bugs are addressed. Additional changes that are targeted for new features and capabilities will not be merged. ## Features requiring API changes If a PR change requires an API change
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Sep 16 21:14:17 UTC 2024 - 4.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* * <p>Currently, this method is invoked while holding a lock. If an implementation of this method * blocks, it can prevent this service from changing state. If you need to performing a blocking * operation in order to trigger shutdown, consider instead registering a listener and * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 13:00:28 UTC 2024 - 7.3K bytes - Viewed (0) -
docs/en/docs/async.md
### Other forms of asynchronous code This style of using `async` and `await` is relatively new in the language. But it makes working with asynchronous code a lot easier.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Aug 28 23:33:37 UTC 2024 - 23.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
} finally { taskRunner.lock.withLock { activeThreads-- startNextTask() } } } } } /** * This blocking queue hooks into a fake clock rather than using regular JVM timing for functions * like [poll]. It is only usable within task faker tasks. */ private inner class TaskFakerBlockingQueue<T>(
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import okio.ByteString /** * A non-blocking interface to a web socket. Use the [factory][WebSocket.Factory] to create * instances; usually this is [OkHttpClient]. * * ## Web Socket Lifecycle *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/grid/muxserver.go
wg.Wait() defer xioutil.SafeClose(handlerIn) m.handleInbound(c, inbound, handlerIn) }(m.inbound) } // Fill outbound block. // Each token represents a message that can be sent to the client without blocking. // The client will refill the tokens as they confirm delivery of the messages. for i := 0; i < outboundCap; i++ { m.outBlock <- struct{}{} } // Handler goroutine.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/main.go
// Main main for minio server. func Main(args []string) { // Set the minio app name. appName := filepath.Base(args[0]) if debugNoExit { freeze := func(_ int) { // Infinite blocking op <-make(chan struct{}) } // Override the logger os.Exit() logger.ExitFunc = freeze defer func() { if err := recover(); err != nil { fmt.Println("panic:", err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 30 22:59:48 UTC 2024 - 6.5K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/AbstractCache.java
/** * Records cache misses. This should be called when a cache request returns a value that was not * found in the cache. This method should be called by the loading thread, as well as by threads * blocking on the load. Multiple concurrent calls to {@link Cache} lookup methods with the same * key on an absent value should result in a single call to either {@code recordLoadSuccess} or
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 15 18:00:07 UTC 2021 - 9.1K bytes - Viewed (0)