- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 39 for removeLast (0.09 seconds)
-
src/main/java/org/codelibs/core/collection/ArrayMap.java
final V value = e.value; removeList(entryIndexOf(e)); e.clear(); return value; } return null; } /** * Removes the entry at the specified index. * * @param index * the index * @return the value of the entry at the specified index */ public V removeAt(final int index) {Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat Nov 22 11:21:59 GMT 2025 - 20.1K bytes - Click Count (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) {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 5.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
override fun runOnce(): Long { log += "run@${taskFaker.nanoTime}" if (schedules.isNotEmpty()) { redQueue.schedule(this, schedules.removeAt(0)) } return delays.removeAt(0) } } redQueue.schedule(task, 100.µs) taskFaker.advanceUntil(0.µs) assertThat(log).isEmpty() taskFaker.advanceUntil(100.µs)Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 23K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/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) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 7.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HeadersCommon.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 6K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
} return result } finally { peekedHeader = null limit = pushedLimit constructed = pushedConstructed if (name != null) path.removeAt(path.size - 1) } } /** * Execute [block] with a new namespace for type hints. Type hints from the enclosing type are no * longer usable by the current type's members. */Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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)Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 3.5K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
takeIndex = inc(takeIndex); --count; return x; } /** * Utility for remove and iterator.remove: Delete item at position i. Call only when occupying * monitor. */ void removeAt(int i) { E[] items = this.items; // if removing front item, just advance if (i == takeIndex) { items[takeIndex] = null; takeIndex = inc(takeIndex); } else {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (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 } /**
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 8.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 8.7K bytes - Click Count (0)