- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 339 for Dequeue (0.18 sec)
-
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/CacheTest.kt
@Test fun redirectToCachedResult() { server.enqueue( MockResponse.Builder() .addHeader("Cache-Control: max-age=60") .body("ABC") .build(), ) server.enqueue( MockResponse.Builder() .code(HttpURLConnection.HTTP_MOVED_PERM) .addHeader("Location: /foo") .build(), ) server.enqueue( MockResponse.Builder() .body("DEF")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 108.6K bytes - Viewed (0) -
pkg/controller/deployment/progress_test.go
expected: time.Duration(-1), }, { name: "complete deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 3, nil), status: newDeploymentStatus(3, 3, 3), expected: time.Duration(-1), }, { name: "already failed deployment does not need to be requeued", d: currentDeployment(&pds, 3, 3, 3, 0, failed), status: newDeploymentStatus(3, 3, 0),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.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) -
pkg/queue/delay.go
// will block until there is room. func DelayQueueBuffer(bufferSize int) DelayQueueOption { return func(queue *delayQueue) { if queue.enqueue != nil { close(queue.enqueue) } queue.enqueue = make(chan *delayTask, bufferSize) } } // DelayQueueWorkers sets the number of background worker goroutines await tasks to execute. Effectively the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
server!!.enqueue(MockResponse()) assertSuccessfulEventOrder() } @Test @Throws(IOException::class) fun multipleDnsLookupsForSingleCall() { server!!.enqueue( MockResponse( code = 301, headers = headersOf("Location", "http://www.fakeurl:" + server!!.port), ), ) server!!.enqueue(MockResponse()) val dns = FakeDns()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CookiesTest.kt
} @Test fun receiveAndSendMultipleCookies() { server.enqueue( MockResponse.Builder() .addHeader("Set-Cookie", "a=android") .addHeader("Set-Cookie", "b=banana") .build(), ) server.enqueue(MockResponse()) val cookieManager = CookieManager(null, CookiePolicy.ACCEPT_ORIGINAL_SERVER) client =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13K bytes - Viewed (0) -
src/main/webapp/js/admin/jquery-3.6.3.min.map
"letter","toUpperCase","camelCase","string","acceptData","owner","Data","uid","defineProperty","configurable","set","data","prop","hasData","dataPriv","dataUser","rbrace","rmultiDash","dataAttr","JSON","parse","removeData","_data","_removeData","dequeue","startLength","hooks","_queueHooks","stop","setter","clearQueue","count","defer","pnum","source","rcssNum","cssExpand","isAttached","composed","getRootNode","isHiddenWithinTree","style","display","css","adjustCSS","valueParts","tween","adjusted"...
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Fri Feb 17 12:13:41 UTC 2023 - 135.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 18.7K bytes - Viewed (0)