- Sort Score
- Num 10 results
- Language All
Results 321 - 330 of 584 for firing (0.04 seconds)
-
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * {@snippet : * final String name = ...; * inFlight.add(name); * ListenableFuture<Result> future = service.query(name); * future.addListener(new Runnable() { * public void run() { * processedCount.incrementAndGet();Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 8K bytes - Click Count (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/AbstractMojo.java
* <code>SystemStreamLog</code> logger will be created and returned. * </p> * <strong>Note:</strong> * The logger returned by this method must not be cached in an instance field during the construction of the mojo. * This would cause the mojo to use a wrongly configured default logger when being run by Maven. The proper logger
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 7.4K bytes - Click Count (0) -
docs/en/docs/tutorial/dependencies/classes-as-dependencies.md
# Classes as Dependencies { #classes-as-dependencies } Before diving deeper into the **Dependency Injection** system, let's upgrade the previous example. ## A `dict` from the previous example { #a-dict-from-the-previous-example } In the previous example, we were returning a `dict` from our dependency ("dependable"): {* ../../docs_src/dependencies/tutorial001_an_py310.py hl[9] *}Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 6.7K bytes - Click Count (0) -
internal/crypto/key.go
Algorithm string // The sealing algorithm used to encrypt the object key. } // Seal encrypts the ObjectKey using the 256 bit external key and IV. The sealed // key is also cryptographically bound to the object's path (bucket/object) and the // domain (SSE-C or SSE-S3). func (key ObjectKey) Seal(extKey []byte, iv [32]byte, domain, bucket, object string) SealedKey { if len(extKey) != 32 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 16 14:27:42 GMT 2025 - 6.2K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
* to lead to trouble than an incompatible change would be. * <li>We could make {@link #countMap} no longer be {@code final}. Then we could write to it * directly during deserialization. However, we would lose Java's guarantees for {@code * final} fields, including that their values are guaranteed to be visible even when an * instance is unsafely published. * </ul> */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Dec 08 22:42:14 GMT 2025 - 22.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/AbstractMapBasedMultiset.java
/** Standard constructor. */ protected AbstractMapBasedMultiset(Map<E, Count> backingMap) { checkArgument(backingMap.isEmpty()); this.backingMap = backingMap; } /** Used during deserialization only. The backing map must be empty. */ void setBackingMap(Map<E, Count> backingMap) { this.backingMap = backingMap; } // Required Implementations /** * {@inheritDoc} *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Aug 11 19:31:30 GMT 2025 - 10.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
@Override public String toString() { return "theDelegate"; } }; Executor sequential1 = newSequentialExecutor(delegate); Executor sequential2 = newSequentialExecutor(delegate); assertThat(sequential1.toString()).contains("theDelegate"); assertThat(sequential1.toString()).isNotEqualTo(sequential2.toString()); String[] whileRunningToString = new String[1];Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 11.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RouteFailureTest.kt
"ConnectionAcquired", "ConnectionReleased", ) } @Test fun proxyMoveTest(cleanClose: Boolean = true) { // Define a single Proxy at myproxy:8008 that will artificially move during the test val proxySelector = RecordingProxySelector() val socketAddress = InetSocketAddress.createUnresolved("myproxy", 8008) proxySelector.proxies.add(Proxy(Proxy.Type.HTTP, socketAddress))
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 11.6K bytes - Click Count (0) -
guava/src/com/google/common/cache/AbstractCache.java
throw new UnsupportedOperationException(); } @Override public ConcurrentMap<K, V> asMap() { throw new UnsupportedOperationException(); } /** * Accumulates statistics during the operation of a {@link Cache} for presentation by {@link * Cache#stats}. This is solely intended for consumption by {@code Cache} implementors. * * @since 10.0 */ public interface StatsCounter {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 9.1K bytes - Click Count (0) -
guava/src/com/google/common/cache/LocalCache.java
@GuardedBy("this") long totalWeight; /** * Number of updates that alter the size of the table. This is used during bulk-read methods to * make sure they see a consistent snapshot: If modCounts change during a traversal of segments * loading size or checking containsValue, then we might have an inconsistent view of state so * (usually) must retry. */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 19:35:11 GMT 2025 - 148.9K bytes - Click Count (0)