- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 912 for removeAt (0.32 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
if (existingIndex != -1) { if (task.nextExecuteNanoTime <= executeNanoTime) { taskRunner.logger.taskLog(task, this) { "already scheduled" } return false } futureTasks.removeAt(existingIndex) // Already scheduled later: reschedule below! } task.nextExecuteNanoTime = executeNanoTime taskRunner.logger.taskLog(task, this) { if (recurrence) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt
path += name try { block(content) constructedBit = if (constructed) 0b0010_0000 else 0 constructed = true // The enclosing object is constructed. } finally { stack.removeAt(stack.size - 1) path.removeAt(path.size - 1) } val sink = sink() // Write the tagClass, tag, and constructed bit. This takes 1 byte if tag is less than 31. if (tag < 31) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-HeadersCommon.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K 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) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
val delays = mutableListOf(TimeUnit.MILLISECONDS.toNanos(1000), -1L) queue.schedule("task", TimeUnit.MILLISECONDS.toNanos(750)) { log.put("runOnce delays.size=${delays.size}") return@schedule delays.removeAt(0) } assertThat(log.take()).isEqualTo("runOnce delays.size=2") val t2 = System.nanoTime() / 1e6 - t1 assertThat(t2).isCloseTo(750.0, 250.0)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K 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) -
operator/cmd/mesh/operator-remove.go
} func operatorRemoveCmd(ctx cli.Context, rootArgs *RootArgs, orArgs *operatorRemoveArgs) *cobra.Command { return &cobra.Command{ Use: "remove", Short: "Removes the Istio operator controller from the cluster.", Long: "The remove subcommand removes the Istio operator controller from the cluster.", Args: func(cmd *cobra.Command, args []string) error { if orArgs.revision == "" && !orArgs.purge {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/tier-sweeper.go
return jentry{}, false } // 1. If bucket versioning is disabled, remove the remote object. // 2. If bucket versioning is suspended and // a. version id is specified, remove its remote object. // b. version id is not specified, remove null version's remote object if it exists. // 3. If bucket versioning is enabled and // a. version id is specified, remove its remote object.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ImmutableListCopyOfConcurrentlyModifiedInputTest.java
runConcurrentlyMutatedTest(elements(1), ops(remove(), add(2)), wrap); runConcurrentlyMutatedTest(elements(1, 2), ops(remove(), remove()), wrap); runConcurrentlyMutatedTest(elements(1, 2), ops(remove(), nop()), wrap); runConcurrentlyMutatedTest(elements(1, 2), ops(remove(), add(3)), wrap); runConcurrentlyMutatedTest(elements(1, 2), ops(nop(), remove()), wrap);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 20:09:59 GMT 2024 - 6.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/PeekingIteratorTest.java
assertEquals("B", peekingIterator.peek()); /* Should complain on attempt to remove() after peek(). */ try { peekingIterator.remove(); fail("remove() should throw IllegalStateException after a peek()"); } catch (IllegalStateException e) { /* expected */ } assertEquals( "After remove() throws exception, peek should still be ok", "B", peekingIterator.peek());
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 9K bytes - Viewed (0)