Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 26 for removeData (0.08 seconds)

  1. 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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 6K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. android/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)
  5. 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)
  6. 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)
  7. src/main/java/org/codelibs/core/collection/ArrayMap.java

        }
    
        /**
         * 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) {
            final Entry<K, V> e = removeList(index);
            final V value = e.value;
            removeMap(e.key);
            e.clear();
            return value;
        }
    
        @Override
    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)
  8. 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)
  9. okhttp/src/commonJvmAndroid/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,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Aug 30 11:30:11 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      private fun startNextTask(): SerialTask? {
        taskRunner.assertLockHeld()
    
        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. */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11.9K bytes
    - Click Count (0)
Back to Top