Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 277 for flow (0.03 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/ActiveProjectArtifact.java

    /**
     * Wraps an active project instance to be able to receive updates from its artifact without affecting the original
     * attributes of this artifact.
     *
     * TODO I think this exposes a design flaw in that the immutable and mutable parts of an artifact are in one class and
     * should be split. ie scope, file, etc depend on the context of use, whereas everything else is immutable.
     */
    @Deprecated
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/EnumMultiset.java

     *
     * @author Jared Levy
     * @since 2.0
     */
    @GwtCompatible
    @J2ktIncompatible
    @SuppressWarnings("EnumOrdinal") // This is one of the low-level utilities where it's suitable.
    public final class EnumMultiset<E extends Enum<E>> extends AbstractMultiset<E>
        implements Serializable {
      /** Creates an empty {@code EnumMultiset}. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java

       * process it; all should produce the same answer, the only difference should be the number of
       * process()/processRemaining() invocations, due to alignment.
       */
      @AndroidIncompatible // slow. TODO(cpovirk): Maybe just reduce iterations under Android.
      public void testExhaustive() throws Exception {
        Random random = new Random(0); // will iteratively make more debuggable, each time it breaks
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  4. cmd/peer-rest-client.go

    	}
    
    	st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload)
    	if err != nil {
    		return
    	}
    	st.Results(func(b []byte) error {
    		select {
    		case traceCh <- b:
    		default:
    			// Do not block on slow receivers.
    			// Just recycle the buffer.
    			grid.PutByteBuffer(b)
    		}
    		return nil
    	})
    }
    
    func (client *peerRESTClient) doListen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/AbstractImmutableSetTest.java

      }
    
      @GwtIncompatible // slow (~40s)
      public void testIterator_oneElement() {
        new IteratorTester<String>(
            5, UNMODIFIABLE, singleton("a"), IteratorTester.KnownOrder.KNOWN_ORDER) {
          @Override
          protected Iterator<String> newTargetIterator() {
            return of("a").iterator();
          }
        }.test();
      }
    
      @GwtIncompatible // slow (~30s)
      public void testIterator_general() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.4K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.20.md

    Initially introduced in 1.18, Kubernetes 1.20 now enables API Priority and Fairness (APF) by default. This allows `kube-apiserver` to [categorize incoming requests by priority levels](https://docs.k8s.io/concepts/cluster-administration/flow-control/).
    
    ### IPv4/IPv6 run
    
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Jan 19 21:05:45 UTC 2022
    - 409K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/xml/XmlEscapers.java

         * replaces the allowed ASCII whitespace characters with themselves and to set the minimum safe
         * character to 0x20. However this would slow down the escaping of simple strings that contain
         * \t, \n, or \r.
         */
        for (char c = MIN_ASCII_CONTROL_CHAR; c <= MAX_ASCII_CONTROL_CHAR; c++) {
          if (c != '\t' && c != '\n' && c != '\r') {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jun 20 17:15:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java

            }
        }
    
        @Test
        @DisplayName("Should evict oldest leases when max limit reached")
        void testMaxLeaseEviction() throws InterruptedException {
            // Create a context with low max lease limit
            Configuration limitedConfig = mock(Configuration.class);
            CIFSContext limitedContext = mock(CIFSContext.class);
            when(limitedContext.getConfig()).thenReturn(limitedConfig);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 00:16:17 UTC 2025
    - 13.2K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

          )
    
        client =
          clientTestRule
            .newClientBuilder()
            .eventListenerFactory(clientTestRule.wrap(listener))
            .connectTimeout(60, TimeUnit.SECONDS) // Deliberately exacerbate slow fallbacks.
            .dns { dnsResults }
            .fastFallback(true)
            .build()
        url =
          serverIpv4
            .url("/")
            .newBuilder()
            .host("localhost")
            .build()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  10. lib/wasm/wasm_exec.js

    			}
    
    			const setInt32 = (addr, v) => {
    				this.mem.setUint32(addr + 0, v, true);
    			}
    
    			const getInt64 = (addr) => {
    				const low = this.mem.getUint32(addr + 0, true);
    				const high = this.mem.getInt32(addr + 4, true);
    				return low + high * 4294967296;
    			}
    
    			const loadValue = (addr) => {
    				const f = this.mem.getFloat64(addr, true);
    				if (f === 0) {
    					return undefined;
    				}
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Sun Dec 08 15:34:47 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top