Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 388 for keep (0.03 sec)

  1. android/guava/src/com/google/common/collect/ImmutableMap.java

          }
        }
    
        /**
         * Associates {@code key} with {@code value} in the built map. If the same key is put more than
         * once, {@link #buildOrThrow} will fail, while {@link #buildKeepingLast} will keep the last
         * value put for that key.
         */
        @CanIgnoreReturnValue
        public Builder<K, V> put(K key, V value) {
          ensureCapacity(size + 1);
          checkEntryNotNull(key, value);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 41.5K bytes
    - Viewed (0)
  2. internal/s3select/json/preader.go

    	kvDstPool   sync.Pool       // pool of []jstream.KV used for output
    	close       chan struct{}   // used for shutting down the splitter before end of stream
    	readerWg    sync.WaitGroup  // used to keep track of async reader.
    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    	input []byte             // raw input sent to the worker
    	dst   chan []jstream.KVS // result of block decode
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    	maxUnconsumedHealResultItems = 1000
    
    	// if no heal-results are consumed (via the heal-status API)
    	// for this timeout duration, the heal sequence is aborted.
    	healUnconsumedTimeout = 24 * time.Hour
    
    	// time-duration to keep heal sequence state after it
    	// completes.
    	keepHealSeqStateDuration = time.Minute * 10
    
    	// nopHeal is a no operating healing action to
    	// wait for the current healing operation to finish
    	nopHeal = ""
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

            taskRunner.condition.await()
          }
        } finally {
          serialTaskQueue.remove(yieldCompleteTask)
        }
    
        // If we're yielding until we're exhausted and a task run, keep going until a task doesn't run.
        if (strategy == ResumePriority.AfterOtherTasks && otherTasksStarted) {
          return yieldUntil(strategy, condition)
        }
      }
    
      private enum class ResumePriority {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  5. docs/en/docs/advanced/events.md

    Including how to handle lifespan state that can be used in other areas of your code.
    
    ///
    
    ## Sub Applications
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:36:22 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. pyproject.toml

    
    [tool.ruff.lint.isort]
    known-third-party = ["fastapi", "pydantic", "starlette"]
    
    [tool.ruff.lint.pyupgrade]
    # Preserve types, even if a file imports `from __future__ import annotations`.
    keep-runtime-typing = true
    
    [tool.inline-snapshot]
    # default-flags=["fix"]
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 22 14:19:56 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  7. cmd/metacache.go

    		// Not finished and update for metacacheMaxRunningAge, discard it.
    		return false
    	case cache.finished() && time.Since(cache.lastHandout) > 5*metacacheMaxClientWait:
    		// Keep for 15 minutes after we last saw the client.
    		// Since the cache is finished keeping it a bit longer doesn't hurt us.
    		return false
    	case cache.status == scanStateError || cache.status == scanStateNone:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/FluentFuture.java

       * AsyncFunction.apply}. Any heavyweight operations should occur in other threads responsible for
       * completing the returned {@code Future}.)
       *
       * <p>The returned {@code Future} attempts to keep its cancellation state in sync with that of the
       * input future and that of the future returned by the chain function. That is, if the returned
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import com.google.common.io.CharSource;
    import com.google.common.primitives.Primitives;
    import com.google.common.primitives.UnsignedInteger;
    import com.google.common.primitives.UnsignedLong;
    import com.google.errorprone.annotations.Keep;
    import java.io.ByteArrayInputStream;
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintStream;
    import java.io.PrintWriter;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  10. cmd/metrics-v3.go

    	}
    
    	// Bucket metrics are special, they always include the bucket label. These
    	// metrics required a list of buckets to be passed to the loader, and the list
    	// of buckets is not known until the request is made. So we keep a separate
    	// map for bucket metrics and handle them specially.
    
    	// Add the serverName and poolIndex labels to all non-cluster metrics.
    	//
    	// Also create metric group maps and set the cache.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 00:55:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
Back to top