- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 4,005 for Receive (0.1 sec)
-
src/time/sleep.go
// it must coordinate with f explicitly. // // For a chan-based timer created with NewTimer(d), as of Go 1.23, // any receive from t.C after Stop has returned is guaranteed to block // rather than receive a stale time value from before the Stop; // if the program has not received from t.C already and the timer is // running, Stop is guaranteed to return true. // Before Go 1.23, the only safe way to use Stop was insert an extra
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/ContainerElementServiceInjectionIntegrationTest.groovy
import org.gradle.process.ExecOperations class ContainerElementServiceInjectionIntegrationTest extends AbstractIntegrationSpec { // Document current behaviour def "container element can receive services through constructor and is not annotated with @Inject"() { buildFile """ class Bean { String name Bean(String name, ObjectFactory factory) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 04 22:26:51 UTC 2021 - 5K bytes - Viewed (0) -
subprojects/build-events/src/test/groovy/org/gradle/internal/build/event/DefaultBuildEventsListenerRegistryTest.groovy
cleanup: signalBuildFinished() } def "listeners receive events concurrently"() { def listener1 = { thread.blockUntil.received instant.handled } as OperationCompletionListener def listener2 = { instant.received thread.blockUntil.handled } as OperationCompletionListener when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 8K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/WorkerProcessBuilder.java
* The worker action is supplied with a {@link WorkerProcessContext} which it can use to receive messages from and send messages to the server process (ie this process). * </p> * * <p>The server process (ie this process) can send messages to and receive message from the worker process using the methods on {@link WorkerProcess#getConnection()}.</p> */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 12:13:32 UTC 2024 - 2.6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHub.java
* <li>{@link Dispatch} to handle incoming messages received from any connections attached to this hub. Each incoming message is passed to exactly one handler associated to the given channel. * </li> * * <li>{@link RejectedMessageListener} to receive notifications of outgoing messages that cannot be sent on the given channel.</li> * * <li>{@link BoundedDispatch} to receive notifications of the end of incoming messages.</li> *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 16.2K bytes - Viewed (0) -
src/encoding/gob/example_test.go
) type P struct { X, Y, Z int Name string } type Q struct { X, Y *int32 Name string } // This example shows the basic usage of the package: Create an encoder, // transmit some values, receive them with a decoder. func Example_basic() { // Initialize the encoder and decoder. Normally enc and dec would be // bound to network connections and the encoder and decoder would // run in different processes.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 02 00:13:47 UTC 2016 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/ListenerManager.java
* * <p>Implementations are thread-safe: A listener is notified by at most 1 thread at a time, and so do not need to be thread-safe. All listeners * of a given type receive events in the same order. Listeners can be added and removed at any time. */ @ServiceScope(Scope.Global.class) public interface ListenerManager { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.6K bytes - Viewed (0) -
docs/en/docs/advanced/websockets.md
## Await for messages and send messages In your WebSocket route you can `await` for messages and send messages. ```Python hl_lines="48-52" {!../../../docs_src/websockets/tutorial001.py!} ``` You can receive and send binary, text, and JSON data. ## Try it If your file is named `main.py`, run your application with: <div class="termy"> ```console $ fastapi dev main.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu May 02 22:37:31 UTC 2024 - 6.2K bytes - Viewed (0) -
docs/em/docs/how-to/custom-request-and-route.md
``` !!! note "📡 ℹ" `Request` ✔️ `request.scope` 🔢, 👈 🐍 `dict` ⚗ 🗃 🔗 📨. `Request` ✔️ `request.receive`, 👈 🔢 "📨" 💪 📨. `scope` `dict` & `receive` 🔢 👯♂️ 🍕 🔫 🔧. & 👈 2️⃣ 👜, `scope` & `receive`, ⚫️❔ 💪 ✍ 🆕 `Request` 👐. 💡 🌅 🔃 `Request` ✅ <a href="https://www.starlette.io/requests/" class="external-link" target="_blank">💃 🩺 🔃 📨</a>.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 3.6K bytes - Viewed (0) -
test/fixedbugs/bug448.dir/pkg2.go
// Copyright 2012 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Issue 3843: inlining bug due to wrong receive operator precedence. package pkg2 import "./pkg1" func F() { pkg1.Do()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 287 bytes - Viewed (0)