- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 277 for enqueue0 (0.23 sec)
-
tensorflow/c/c_api_experimental.h
// empty, this call is blocked. // // Tensors are enqueued via the corresponding TF enqueue op. // TODO(hongm): Add support for `timeout_ms`. TF_CAPI_EXPORT extern TF_Tensor* TF_DequeueNamedTensor(TF_Session* session, int tensor_id, TF_Status* status); // On success, enqueues `tensor` into a TF-managed FifoQueue given by
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/ExclusiveCacheAccessingWorkerTest.groovy
given: def counter = 0 def failure = new RuntimeException() start(cacheAccessWorker) when: cacheAccessWorker.enqueue { throw failure } cacheAccessWorker.enqueue { throw new RuntimeException() } cacheAccessWorker.enqueue { counter++ } cacheAccessWorker.flush() then: counter == 1 def e = thrown(RuntimeException) e == failure
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 4.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 1)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 4)); queue.enqueue(THROWING_EVENT);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 1)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(THROWING_EVENT); queue.enqueue(incrementingEvent(counters, listener, 4)); queue.enqueue(THROWING_EVENT);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 09 22:57:07 UTC 2022 - 8.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
@Test fun connectionPooling_Async() { server.enqueue(MockResponse(body = "abc")) server.enqueue(MockResponse(body = "def")) server.enqueue(MockResponse(body = "ghi")) client.newCall(Request.Builder().url(server.url("/a")).build()).enqueue(callback) callback.await(server.url("/a")).assertBody("abc") client.newCall(Request.Builder().url(server.url("/b")).build()).enqueue(callback)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
server.enqueue(MockResponse()) val request = Request.Builder() .url(server.url("/")) .post(sleepingRequestBody(500)) .build() val latch = CountDownLatch(1) val exceptionRef = AtomicReference<Throwable>() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) call.enqueue( object : Callback {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
) { setUp(protocol, mockWebServer) server.enqueue( MockResponse.Builder() .body(Buffer().write(ByteArray(Http2Connection.OKHTTP_CLIENT_WINDOW_SIZE + 1))) .build(), ) server.enqueue( MockResponse(body = "abc"), ) // Enqueue an additional response that show if we burnt a good prior response. server.enqueue( MockResponse(body = "XXX"), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
} override fun writeTo(sink: BufferedSink) { sink.writeUtf8("<element/>") sink.flush() } } server.enqueue(MockResponse(code = 201)) server.enqueue(MockResponse(code = 204)) server.enqueue(MockResponse(code = 204)) val endpointUrl = server.url("/endpoint") var request = Request.Builder() .url(endpointUrl)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 8.4K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
.build() server.enqueue( MockResponse.Builder() .headersDelay(500, TimeUnit.MILLISECONDS) .setHeader("content-type", "text/event-stream") .body("data: hey\n\n") .build(), ) newEventSource() listener.assertFailure("timeout") } @Test fun retainsAccept() { server.enqueue( MockResponse.Builder() .body(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 6.6K bytes - Viewed (0)