Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 313 for flow (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. CONTRIBUTING.md

    worth investing the substantial effort needed to review them. This especially
    includes changes suggested by tools.
    
    We sometimes reject contributions due to the low quality of the submission
    since low-quality submissions tend to take unreasonable effort to review
    properly. Quality is rather subjective so it is hard to describe exactly how to
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Wed Sep 01 07:32:01 GMT 2021
    - 36.5K bytes
    - Click Count (0)
  2. android/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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Oct 28 18:19:59 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  3. docs/tr/docs/async.md

    Bu sırada bilgisayar, "slow-file" 📝 biterken gidip başka işler yapabilir.
    
    Sonra bilgisayar / program 🤖, ya tekrar beklediği için ya da o anda elindeki tüm işleri bitirdiğinde fırsat buldukça geri gelir. Ve beklediği görevlerden herhangi biri bittiyse, yapılması gerekenleri yapar.
    
    Ardından, 🤖 ilk biten görevi alır (örneğin bizim "slow-file" 📝) ve onunla yapması gerekenlere devam eder.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 07:53:17 GMT 2026
    - 23.7K bytes
    - Click Count (0)
  4. build-tools-internal/src/main/resources/forbidden/third-party-audit.txt

    # Side Public License, v 1.
    
    # Checks that we run against bytecode of third-party dependencies
    #
    # Be judicious about what is denied here: MANY classes will be subject
    # to these rules, so please try to keep the false positive rate low!
    #
    # Each third party .class failing checks will need to be explicitly
    # listed in the module's build.gradle file:
    #
    #   thirdPartyAudit.excludes = [
    #    // uses internal java api: sun.misc.Unsafe
    #    'org.foo.Bar',
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 3K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbPipeHandleInternal.java

    import jcifs.SmbPipeHandle;
    
    /**
     * Internal interface for SMB pipe handle operations.
     *
     * This interface extends SmbPipeHandle with additional methods needed
     * for internal pipe management and provides access to low-level pipe details.
     *
     * @author mbechler
     *
     * <p>This interface is intended for internal use.</p>
     */
    public interface SmbPipeHandleInternal extends SmbPipeHandle {
    
        /**
         * Gets the type of this pipe.
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

            blocker = (Blocker) state;
          }
          spinCount++;
          if (spinCount > MAX_BUSY_WAIT_SPINS) {
            /*
             * If we have spun a lot, just park ourselves. This will save CPU while we wait for a slow
             * interrupting thread. In theory, interruptTask() should be very fast, but due to
             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  7. docs/uk/docs/async.md

    Асинхронний код означає, що мова 💬 має спосіб сказати комп’ютеру/програмі 🤖, що в певний момент у коді він 🤖 має почекати, поки «щось інше» завершиться десь ще. Скажімо, це «щось інше» називається «slow-file» 📝.
    
    Отже, в цей час комп’ютер може піти і зробити іншу роботу, доки «slow-file» 📝 завершується.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:27:41 GMT 2026
    - 36.6K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/base/Platform.java

        // If anyone in our monorepo uses the Android copy of Guava on a JVM, that would be unfortunate.
        // But that is only likely to happen in Robolectric tests, where the risks of JDK regex are low.
        return new JdkPatternCompiler();
      }
    
      private static final class JdkPatternCompiler implements PatternCompiler {
        @Override
        public CommonPattern compile(String pattern) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 29 17:36:00 GMT 2025
    - 4.1K bytes
    - Click Count (0)
  9. 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() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 18.5K bytes
    - Click Count (0)
  10. 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) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
Back to Top