Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,026 for removeAt (0.05 sec)

  1. 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)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 23K bytes
    - Viewed (0)
  2. 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) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  3. 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) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HeadersCommon.kt

      apply {
        var i = 0
        while (i < namesAndValues.size) {
          if (name.equals(namesAndValues[i], ignoreCase = true)) {
            namesAndValues.removeAt(i) // name
            namesAndValues.removeAt(i) // value
            i -= 2
          }
          i += 2
        }
      }
    
    /**
     * Set a field with the specified value. If the field is not found, it is added. If the field is
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  5. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

        E x = items[takeIndex];
        items[takeIndex] = null;
        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;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  6. 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.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        assertTrue("Could not remove larry", mmHeap.remove("larry"));
        assertEquals(6, mmHeap.size());
        assertFalse("heap contains larry which has been removed", mmHeap.contains("larry"));
        assertTrue("heap does not contain sergey", mmHeap.contains("sergey"));
        assertTrue("Could not remove larry", mmHeap.removeAll(Lists.newArrayList("sergey", "eric")));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 36K bytes
    - Viewed (0)
  8. 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)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

          } else {
            readyQueues.remove(taskQueue)
          }
        }
    
        if (coordinatorWaiting) {
          backend.coordinatorNotify(this@TaskRunner)
        } else {
          startAnotherThread()
        }
      }
    
      private fun beforeRun(task: Task) {
        assertLockHeld()
    
        task.nextExecuteNanoTime = -1L
        val queue = task.queue!!
        queue.futureTasks.remove(task)
        readyQueues.remove(queue)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  10. 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
    }
    
    /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.3K bytes
    - Viewed (0)
Back to top