- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 124 for Coroutine (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)