Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 699 for takeIf (0.05 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

        recurrence: Boolean,
      ): Boolean {
        task.initQueue(this)
    
        val now = taskRunner.backend.nanoTime()
        val executeNanoTime = now + delayNanos
    
        // If the task is already scheduled, take the earlier of the two times.
        val existingIndex = futureTasks.indexOf(task)
        if (existingIndex != -1) {
          if (task.nextExecuteNanoTime <= executeNanoTime) {
    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)
  2. .github/ISSUE_TEMPLATE/feature_addition_request.yaml

            forking Guava yourself.
    
    
            We want to see that new features have some significant advantage over the alternatives.
            These advantages can take
            [many forms](https://github.com/google/guava/wiki/PhilosophyExplained#utility), but taking
            the time to discuss them in detail will make it much clearer why this feature should be
            added to Guava.
    
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Nov 17 18:47:47 GMT 2023
    - 5.8K bytes
    - Click Count (0)
  3. chainable_api.go

    	}
    	return
    }
    
    var tableRegexp = regexp.MustCompile(`(?i)(?:.+? AS (\w+)\s*(?:$|,)|^\w+\s+(\w+)$)`)
    
    // Table specify the table you would like to run db operations
    //
    //	// Get a user
    //	db.Table("users").Take(&result)
    func (db *DB) Table(name string, args ...interface{}) (tx *DB) {
    	tx = db.getInstance()
    	if strings.Contains(name, " ") || strings.Contains(name, "`") || len(args) > 0 {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Sep 19 01:49:06 GMT 2025
    - 14.8K bytes
    - Click Count (0)
  4. docs/bigdata/README.md

    ```
    sudo pip install yq
    alias kv-pairify='yq ".configuration[]" | jq ".[]" | jq -r ".name + \"=\" + .value"'
    ```
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionSpec.kt

          } else {
            sslSocket.enabledProtocols
          }
    
        // In accordance with https://tools.ietf.org/html/draft-ietf-tls-downgrade-scsv-00 the SCSV
        // cipher is added to signal that a protocol fallback has taken place.
        val supportedCipherSuites = sslSocket.supportedCipherSuites
        val indexOfFallbackScsv =
          supportedCipherSuites.indexOf(
            "TLS_FALLBACK_SCSV",
            CipherSuite.ORDER_BY_NAME,
          )
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jan 10 09:36:53 GMT 2026
    - 13.5K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/TreeBasedTable.java

     * a {@code Map<R, Map<C, V>>}. A method call like {@code column(columnKey).get(rowKey)} still runs
     * quickly, since the row key is provided. However, {@code column(columnKey).size()} takes longer,
     * since an iteration across all row keys occurs.
     *
     * <p>Because a {@code TreeBasedTable} has unique sorted values for a given row, both {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 18 15:05:43 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  7. README.md

        $ mvn package     # Build the package
    
    #### 2. Start Fess Server
    
        $ unzip target/releases/fess-*.zip
        $ ./fess-*/bin/fess &
    
    Wait for Fess to be ready (this may take up to 60 seconds):
    
        $ curl -s "http://localhost:8080/api/v1/health"
    
    You should see a JSON response when Fess is ready.
    
    #### 3. Clone Test Data
    
    Required for SearchApiTests:
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Feb 14 03:19:23 GMT 2026
    - 7.8K bytes
    - Click Count (2)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

                val delayNanos =
                  logger.logElapsed(task, task.queue!!) {
                    task.runOnce()
                  }
    
                // A task ran successfully. Update the execution state and take the next task.
                task = withLock {
                  afterRun(task, delayNanos, true)
                  awaitTaskToRun()
                } ?: return
              }
            } catch (thrown: Throwable) {
    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)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        override fun peek(): T = error("unsupported")
    
        override fun offer(
          element: T,
          timeout: Long,
          unit: TimeUnit,
        ) = error("unsupported")
    
        override fun take() = error("unsupported")
    
        override fun remainingCapacity() = error("unsupported")
    
        override fun drainTo(sink: MutableCollection<in T>) = error("unsupported")
    
        override fun drainTo(
    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)
  10. android/guava/src/com/google/common/math/LinearTransformation.java

       * itself. In all other cases, the inverse is a transformation such that applying both the
       * original transformation and its inverse to a value gives you the original value give-or-take
       * numerical errors. Calling this method multiple times on the same instance will always return
       * the same instance. Calling this method on the result of calling this method on an instance will
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Aug 11 19:31:30 GMT 2025
    - 9.7K bytes
    - Click Count (0)
Back to Top