- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 4,005 for Receive (0.14 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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting_test.go
func() { lock.Lock() defer lock.Unlock() if wr.Set(bval) { t.Error("second Set() returned true") } }() goGetAndExpect(t, clock, counter, wr, gots, aval) counter.Add(1) // account for unblocking the receive on doneCh close(doneCh) time.Sleep(time.Second) // give it a chance to misbehave goGetAndExpect(t, clock, counter, wr, gots, aval) } func TestCountingWriteOnceCancel(t *testing.T) { oldTime := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 10 14:37:53 UTC 2021 - 4.6K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen_test.go
// to represent the names. The protocol is based on GRPC resolution of XDS resources. func TestAPIGen(t *testing.T) { ds := initDS(t) // Verify we can receive the DNS cluster IPs using XDS t.Run("adsc", func(t *testing.T) { proxy := &model.Proxy{Metadata: &model.NodeMetadata{ Generator: "api", }} adscConn := ds.ConnectUnstarted(ds.SetupProxy(proxy), xds.APIWatches())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
* synchronization to safely receive incoming data frames, it is not intended for use by multiple * readers. */ inner class FramingSource internal constructor( /** Maximum number of bytes to buffer before reporting a flow control error. */ private val maxByteCount: Long, /** * True if either side has cleanly shut down this stream. We will receive no more bytes beyond
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
docs/en/docs/tutorial/request-forms.md
# Form Data When you need to receive form fields instead of JSON, you can use `Form`. !!! info To use forms, first install <a href="https://github.com/Kludex/python-multipart" class="external-link" target="_blank">`python-multipart`</a>. E.g. `pip install python-multipart`. ## Import `Form` Import `Form` from `fastapi`: === "Python 3.9+" ```Python hl_lines="3"
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Mar 13 19:02:19 UTC 2024 - 3.2K bytes - Viewed (0) -
docs/en/docs/reference/uploadfile.md
# `UploadFile` class You can define *path operation function* parameters to be of the type `UploadFile` to receive files from the request. You can import it directly from `fastapi`: ```python from fastapi import UploadFile ``` ::: fastapi.UploadFile options: members: - file - filename - size - headers - content_type - read
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 472 bytes - Viewed (0) -
manifests/charts/istio-operator/files/profile-openshift-ambient.yaml
logLevel: info provider: "multus" pilot: cni: enabled: true provider: "multus" variant: distroless env: PILOT_ENABLE_AMBIENT: "true" # Allow sidecars/ingress to send/receive HBONE. This is required for interop. PILOT_ENABLE_SENDING_HBONE: "true" PILOT_ENABLE_SIDECAR_LISTENING_HBONE: "true" platform: openshift variant: distroless seLinuxOptions:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 30 20:24:06 UTC 2024 - 883 bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/TestProgressCrossVersionSpec.groovy
ex.causes == [failure] and: "expected events received" resultsOfFirstListener.size() == 1 resultsOfLastListener.size() == 1 and: "build execution is successful" assertHasBuildSuccessfulLogging() } def "receive test progress events for successful test run"() { given: buildFile << """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 06 06:59:43 UTC 2024 - 21.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/promise/counting.go
go func() { defer activeCounter.Add(-1) // count completion of this goroutine defer runtime.HandleCrash() activeCounter.Add(-1) // count suspension for channel receive <-doneCh // Whatever goroutine unblocked the preceding receive MUST // have already accounted for this activation. lock.Lock() defer lock.Unlock() p.Set(doneVal) }() } return p }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 10 14:37:53 UTC 2021 - 3.3K bytes - Viewed (0) -
src/runtime/chan.go
chanrecv(c, elem, true) } //go:nosplit func chanrecv2(c *hchan, elem unsafe.Pointer) (received bool) { _, received = chanrecv(c, elem, true) return } // chanrecv receives on channel c and writes the received data to ep. // ep may be nil, in which case received data is ignored. // If block == false and no elements are available, returns (false, false).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0)