Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  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. 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)
  7. 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)
  8. 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)
  9. android/guava-tests/test/com/google/common/collect/ContiguousSetTest.java

        assertTrue(enormous instanceof RegularContiguousSet);
        // We can't use reserializeAndAssert because it calls hashCode, which is enormously slow.
        ContiguousSet<Integer> enormousReserialized = reserialize(enormous);
        assertEquals(enormous, enormousReserialized);
      }
    
      private static final DiscreteDomain<Integer> UNBOUNDED_THROWING_DOMAIN =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.6K bytes
    - Viewed (0)
  10. src/test/java/jcifs/util/SmbCircuitBreakerTest.java

                });
    
                cbWithMetrics.executeWithCircuitBreaker(() -> {
                    try {
                        Thread.sleep(300);
                    } catch (InterruptedException e) {}
                    return "slow";
                });
    
                // Check metrics
                assertTrue(cbWithMetrics.getAverageResponseTime() > 0, "Average response time should be tracked");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 23.2K bytes
    - Viewed (0)
Back to top