Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 124 for Coroutine (0.32 sec)

  1. README.md

        which does not export it to module com.bigco.sdk)
    ```
    
    The stable public API is based on the list of defined modules:
    
    - okhttp3
    - okhttp3.brotli
    - okhttp3.coroutines
    - okhttp3.dnsoverhttps
    - okhttp3.java.net.cookiejar
    - okhttp3.logging
    - okhttp3.sse
    - okhttp3.tls
    - okhttp3.urlconnection
    - mockwebserver3
    - mockwebserver3.junit4
    - mockwebserver3.junit5
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Oct 30 21:39:59 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  2. internal/s3select/csv/reader.go

    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *Reader) startReaders(newReader func(io.Reader) *csv.Reader) error {
    	if r.args.FileHeaderInfo != none {
    		// Read column names
    		// Get one line.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. internal/logger/logger.go

    	sendLog(ctx, entry)
    }
    
    // ErrCritical is the value panic'd whenever CriticalIf is called.
    var ErrCritical struct{}
    
    // CriticalIf logs the provided error on the console. It fails the
    // current go-routine by causing a `panic(ErrCritical)`.
    func CriticalIf(ctx context.Context, err error, errKind ...any) {
    	if err != nil {
    		LogIf(ctx, "", err, errKind...)
    		panic(ErrCritical)
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  4. cmd/metrics-v3-types.go

    		err = mg.bucketLoader(GlobalContext, metricValues, mg.cache, mg.buckets)
    	} else {
    		err = mg.loader(GlobalContext, metricValues, mg.cache)
    	}
    
    	// There is no way to handle errors here, so we panic the current goroutine
    	// and the Metrics API handler returns a 500 HTTP status code. This should
    	// normally not happen, and usually indicates a bug.
    	logger.CriticalIf(GlobalContext, errors.Wrap(err, "failed to get metrics"))
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Feb 28 19:33:08 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  5. cmd/iam-etcd-store.go

    		err = errNoSuchGroup
    	}
    	return err
    }
    
    func (ies *IAMEtcdStore) watch(ctx context.Context, keyPath string) <-chan iamWatchEvent {
    	ch := make(chan iamWatchEvent)
    
    	// go routine to read events from the etcd watch channel and send them
    	// down `ch`
    	go func() {
    		for {
    		outerLoop:
    			watchCh := ies.client.Watch(ctx,
    				keyPath, etcd.WithPrefix(), etcd.WithKeysOnly())
    
    			for {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    				nsMutex:            mutex,
    			}
    		}(i)
    	}
    
    	wg.Wait()
    
    	// start cleanup stale uploads go-routine.
    	go s.cleanupStaleUploads(ctx)
    
    	// start cleanup of deleted objects.
    	go s.cleanupDeletedObjects(ctx)
    
    	// Start the disk monitoring and connect routine.
    	if !globalIsTesting {
    		go s.monitorAndConnectEndpoints(ctx, defaultMonitorConnectEndpointInterval)
    	}
    
    	return s, nil
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  7. internal/logger/target/http/http.go

    			retryIntvl = 3 * time.Second
    		}
    
    		maxRetries := h.config.MaxRetry
    
    	retry:
    		// If the channel reaches above half capacity
    		// we spawn more workers. The workers spawned
    		// from this main worker routine will exit
    		// once the channel drops below half capacity
    		// and when it's been at least 30 seconds since
    		// we launched a new worker.
    		if mainWorker && len(h.logCh) > cap(h.logCh)/2 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                throw new UnknownHostException(name.name);
            }
    
            /* If a target address to query was not specified explicitly
             * with the addr parameter we fall into this resolveOrder routine.
             */
    
            for (final int element : resolveOrder) {
                try {
                    switch (element) {
                    case RESOLVER_LMHOSTS:
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/netbios/NameServiceClientImpl.java

                throw new UnknownHostException(name.name);
            }
    
            /*
             * If a target address to query was not specified explicitly
             * with the addr parameter we fall into this resolveOrder routine.
             */
    
            for (final ResolverType resolverType : this.resolveOrder) {
                try {
                    switch (resolverType) {
                    case RESOLVER_LMHOSTS:
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 38.5K bytes
    - Viewed (0)
  10. docs/pt/docs/async.md

    Nas versões anteriores do NodeJS / Navegador JavaScript, você utilizaria "callbacks". O que leva ao "inferno do callback".
    
    ## Corrotinas { #coroutines }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Nov 12 16:23:57 UTC 2025
    - 25.8K bytes
    - Viewed (0)
Back to top