- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for removeMax (0.16 sec)
-
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
if (value == 8) { iter.remove(); } } assertIntact(q); assertThat(result).containsExactly(1, 15, 13, 8, 14); } /** * This tests a special case of the removeAt() call. Moving an element sideways on the heap could * break the invariants. Sometimes we need to bubble an element up instead of trickling down. See * implementation. */ public void testInvalidatingRemove() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt
mergeAdjacent@ while (j < ranges.size) { val next = ranges[j] if (next is MappedRange.InlineDelta && curr.codepointDelta == next.codepointDelta ) { ranges.removeAt(j) } else { break@mergeAdjacent } } } i++ } return ranges } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
if (value == 8) { iter.remove(); } } assertIntact(q); assertThat(result).containsExactly(1, 15, 13, 8, 14); } /** * This tests a special case of the removeAt() call. Moving an element sideways on the heap could * break the invariants. Sometimes we need to bubble an element up instead of trickling down. See * implementation. */ public void testInvalidatingRemove() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0) -
istioctl/pkg/tag/tag_test.go
} for _, tc := range tcs { t.Run(tc.name, func(t *testing.T) { var out bytes.Buffer client := fake.NewSimpleClientset(tc.webhooksBefore.DeepCopyObject(), tc.namespaces.DeepCopyObject()) err := removeTag(context.Background(), client, tc.tag, tc.skipConfirmation, &out) if tc.error == "" && err != nil { t.Fatalf("expected no error, got %v", err) } if tc.error != "" { if err == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Nov 17 22:41:06 GMT 2023 - 8.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
* close the socket as soon as this frame has been written; otherwise the peer stays open until * explicitly closed. */ fun truncateLastFrame(length: Int): Http2Writer { val lastFrame = outFrames.removeAt(outFrames.size - 1) require(length < bytesOut.size - lastFrame.start) // Move everything from bytesOut into a new buffer. val fullBuffer = Buffer() bytesOut.read(fullBuffer, bytesOut.size)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
} for (i in readyQueues.size - 1 downTo 0) { val queue = readyQueues[i] queue.cancelAllAndDecide() if (queue.futureTasks.isEmpty()) { readyQueues.removeAt(i) } } } interface Backend { fun nanoTime(): Long fun coordinatorNotify(taskRunner: TaskRunner) fun coordinatorWait( taskRunner: TaskRunner,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
"A connection to ${connection.route().address.url} was leaked. " + "Did you forget to close a response body?" Platform.get().logCloseableLeak(message, callReference.callStackTrace) references.removeAt(i) // If this was the last allocation, the connection is eligible for immediate eviction. if (references.isEmpty()) { connection.idleAtNs = now - keepAliveDurationNs return 0 }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
private fun startNextTask(): SerialTask? { taskRunner.assertThreadHoldsLock() val index = serialTaskQueue.indexOfFirst { it.isReady() } if (index == -1) return null val nextTask = serialTaskQueue.removeAt(index) currentTask = nextTask contextSwitchCount++ nextTask.start() return nextTask } private interface SerialTask { /** Returns true if this task is ready to start. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
val connection = this.connection!! connection.lock.assertHeld() val calls = connection.calls val index = calls.indexOfFirst { it.get() == this@RealCall } check(index != -1) calls.removeAt(index) this.connection = null if (calls.isEmpty()) { connection.idleAtNs = System.nanoTime() if (connectionPool.connectionBecameIdle(connection)) { return connection.socket()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
for (i in encodedQueryNamesAndValues!!.size - 2 downTo 0 step 2) { if (canonicalName == encodedQueryNamesAndValues!![i]) { encodedQueryNamesAndValues!!.removeAt(i + 1) encodedQueryNamesAndValues!!.removeAt(i) if (encodedQueryNamesAndValues!!.isEmpty()) { encodedQueryNamesAndValues = null return } } } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1)