- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 3,454 for sreceiver (0.65 sec)
-
testing/internal-integ-testing/src/test/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServerTest.groovy
'Did not receive all expected requests. Waiting for 1 further requests, received [], released [], not yet received [GET /a]', 'Did not receive all expected requests. Waiting for 1 further requests, received [], released [], not yet received [GET /b]', 'Did not receive all expected requests. Waiting for 1 further requests, received [], released [], not yet received [GET /c, GET /d]',
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 46.1K bytes - Viewed (0) -
src/os/signal/example_test.go
// Set up channel on which to send signal notifications. // We must use a buffered channel or risk missing the signal // if we're not ready to receive when the signal is sent. c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt) // Block until a signal is received. s := <-c fmt.Println("Got signal:", s) } func ExampleNotify_allSignals() { // Set up channel on which to send signal notifications.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 18:38:23 UTC 2017 - 1001 bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Response.java
/** * */ public interface Response extends Message { /** * * @return whether the response is received */ boolean isReceived (); /** * Set received status */ void received (); /** * Unset received status */ void clearReceived (); /** * * @return number of credits granted by the server */
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 2.3K bytes - Viewed (0) -
samples/open-telemetry/als/README.md
```yaml receivers: otlp: protocols: grpc: http: processors: batch: exporters: logging: loglevel: debug service: pipelines: logs: receivers: [otlp] processors: [batch]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 18 16:38:12 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-core/src/test/kotlin/org/gradle/internal/declarativedsl/mappingToJvm/AccessorTest.kt
} @Test fun `triggers the custom accessor with empty block`() { val resolution = schema.resolve("configureCustomInstance { }") assertTrue(runtimeInstanceFromResult(schema, resolution, configureLambdas, runtimeCustomAccessors, ::MyReceiver).myHiddenInstance.isInitialized()) } @Test
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 11:58:18 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/core-configuration/declarative-dsl-core/src/main/kotlin/org/gradle/internal/declarativedsl/objectGraph/AssignmentResolver.kt
} } private fun withResolvedReceiver(objectOrigin: ObjectOrigin.HasReceiver, ifReceiverResolved: (receiver: ObjectOrigin) -> ObjectOrigin): ExpressionResolutionProgress { val receiver = objectOrigin.receiver return withResolved(receiver, ifReceiverResolved) } sealed interface ResolutionNode {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 12:25:46 UTC 2024 - 9.6K bytes - Viewed (0) -
test/typeparam/chansimp.dir/a.go
// the receiver stops reading them. func Ranger[Elem any]() (*Sender[Elem], *Receiver[Elem]) { c := make(chan Elem) d := make(chan struct{}) s := &Sender[Elem]{ values: c, done: d, } r := &Receiver[Elem]{ values: c, done: d, } runtime.SetFinalizer(r, (*Receiver[Elem]).finalize) return s, r } // A Sender is used to send values to a Receiver. type Sender[Elem any] struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 28 21:40:40 UTC 2021 - 5.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2Response.java
*/ @Override public final void clearReceived () { this.received = false; } /** * {@inheritDoc} * * @see jcifs.util.transport.Response#isReceived() */ @Override public final boolean isReceived () { return this.received; } /** * {@inheritDoc} *
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Aug 05 09:45:59 UTC 2018 - 7.4K bytes - Viewed (0) -
samples/open-telemetry/loki/otel.yaml
ports: - name: grpc-opencensus port: 55678 protocol: TCP targetPort: 55678 - name: grpc-otlp # Default endpoint for OpenTelemetry receiver. port: 4317 protocol: TCP targetPort: 4317 selector: app: opentelemetry-collector --- apiVersion: apps/v1 kind: Deployment metadata: name: opentelemetry-collector spec: selector: matchLabels:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 06 20:18:25 UTC 2023 - 3.1K bytes - Viewed (0) -
src/runtime/export_unix_test.go
} // WaitForSigusr1 blocks until a SIGUSR1 is received. It calls ready // when it is set up to receive SIGUSR1. The ready function should // cause a SIGUSR1 to be sent. The r and w arguments are a pipe that // the signal handler can use to report when the signal is received. // // Once SIGUSR1 is received, it returns the ID of the current M and // the ID of the M the SIGUSR1 was received on. If the caller writes
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 20 21:27:51 UTC 2023 - 2.3K bytes - Viewed (0)