Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 710 for continue (0.13 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * a no-op. We could log, but if that's what we really want, we should modify
         * AbstractFuture.executeListener to do so, since that method would have the ability to continue
         * to execute other listeners.
         *
         * What about RuntimeException? If there is a bug in set()/setValue() that produces one, it will
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. docs/pt/docs/how-to/custom-docs-ui-assets.md

    ## Hospedagem Própria de JavaScript e CSS para a documentação
    
    Hospedar o JavaScript e o CSS pode ser útil se, por exemplo, você precisa que seu aplicativo continue funcionando mesmo offline, sem acesso aberto à Internet, ou em uma rede local.
    
    Aqui você verá como providenciar esses arquivos você mesmo, no mesmo aplicativo FastAPI, e configurar a documentação para usá-los.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Oct 18 12:02:35 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

            streamId = 0,
            length = settings.size() * 6,
            type = TYPE_SETTINGS,
            flags = FLAG_NONE,
          )
          for (i in 0 until Settings.COUNT) {
            if (!settings.isSet(i)) continue
            val id =
              when (i) {
                4 -> 3 // SETTINGS_MAX_CONCURRENT_STREAMS renumbered.
                7 -> 4 // SETTINGS_INITIAL_WINDOW_SIZE renumbered.
                else -> i
              }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/LoadingCache.java

       */
      @Deprecated
      @Override
      V apply(K key);
    
      /**
       * Loads a new value for {@code key}, possibly asynchronously. While the new value is loading the
       * previous value (if any) will continue to be returned by {@code get(key)} unless it is evicted.
       * If the new value is loaded successfully it will replace the previous value in the cache; if an
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Aug 06 17:12:03 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  5. cmd/ftp-server-driver.go

    		Prefix:    prefix,
    		Recursive: false,
    	}) {
    		if object.Err != nil {
    			return object.Err
    		}
    
    		if object.Key == prefix {
    			continue
    		}
    
    		isDir := strings.HasSuffix(object.Key, SlashSeparator)
    		info := minioFileInfo{
    			p:     pathClean(strings.TrimPrefix(object.Key, prefix)),
    			info:  object,
    			isDir: isDir,
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  6. istioctl/pkg/dashboard/dashboard.go

    		if err != nil {
    			return fmt.Errorf("could not build port forwarder for %s: %v", flavor, err)
    		}
    
    		if err = fw.Start(); err != nil {
    			fw.Close()
    			// Try the next port
    			continue
    		}
    
    		// Close the port forwarder when the command is terminated.
    		ClosePortForwarderOnInterrupt(fw)
    
    		log.Debugf(fmt.Sprintf("port-forward to %s pod ready", flavor))
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  7. guava/src/com/google/common/base/Stopwatch.java

     * behavior of the stopwatch.
     *
     * <p><b>Note:</b> This class is not thread-safe.
     *
     * <p><b>Warning for Android users:</b> a stopwatch with default behavior may not continue to keep
     * time while the device is asleep. Instead, create one like this:
     *
     * <pre>{@code
     * Stopwatch.createStarted(
     *      new Ticker() {
     *        public long read() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java

            }
            for (final TermQuery tq : termQueryList) {
                final String text = tq.getTerm().text();
                if (0 == text.length() || keywords.contains(text)) {
                    continue;
                }
                keywords.add(text);
            }
            return keywords;
        }
    
        public static List<TermQuery> getTermQueryList(final Query query, final String[] fields) {
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. internal/s3select/csv/reader.go

    		}
    	}()
    
    	// Start parsers
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		go func() {
    			for in := range r.input {
    				if len(in.input) == 0 {
    					in.dst <- nil
    					continue
    				}
    				dst, ok := r.csvDstPool.Get().([][]string)
    				if !ok {
    					dst = make([][]string, 0, 1000)
    				}
    
    				cr := newReader(bytes.NewBuffer(in.input))
    				all := dst[:0]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. internal/event/targetlist.go

    	}
    }
    
    func (list *TargetList) sendSync(event Event, targetIDset TargetIDSet) {
    	var wg sync.WaitGroup
    	for id := range targetIDset {
    		target, ok := list.get(id)
    		if !ok {
    			continue
    		}
    		wg.Add(1)
    		go func(id TargetID, target Target) {
    			list.currentSendCalls.Add(1)
    			list.incCurrentSendCalls(id)
    			list.incTotalEvents(id)
    			defer list.decCurrentSendCalls(id)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
Back to top