Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 245 for Publish (0.06 sec)

  1. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

      fun testLoggingLevels() {
        enableTls()
    
        val testHandler =
          object : Handler() {
            val calls = mutableMapOf<String, AtomicInteger>()
    
            override fun publish(record: LogRecord) {
              calls
                .getOrPut(record.loggerName) { AtomicInteger(0) }
                .incrementAndGet()
            }
    
            override fun flush() {
            }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 14:12:28 UTC 2025
    - 29K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

        try {
          reader!!.processNextFrame()
          receivedCloseCode == -1
        } catch (e: Exception) {
          failWebSocket(e = e)
          false
        }
    
      /**
       * Clean up and publish necessary close events when the reader is done. Invoked only by the reader
       * thread.
       */
      fun finishReader() {
        val code: Int
        val reason: String?
        val sendOnClosed: Boolean
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance.go

    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceRebalance) > 0 {
    			globalTrace.Publish(rebalanceTrace(r, poolIdx, startTime, duration, err, strings.Join(paths, " "), sz))
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

       *     CLEAN or REMOVE indicate that temporary files may need to be deleted.
       *
       *   o CLEAN lines track a cache entry that has been successfully published and may be read. A
       *     publish line is followed by the lengths of each of its values.
       *
       *   o READ lines track accesses for LRU.
       *
       *   o REMOVE lines track entries that have been deleted.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/LegacyRepositorySystem.java

                throw new ArtifactDoesNotExistException(getMessage(e, "Requested artifact does not exist."), e);
            }
        }
    
        @Override
        public void publish(
                ArtifactRepository repository, File source, String remotePath, ArtifactTransferListener transferListener)
                throws ArtifactTransferFailedException {
            try {
                wagonManager.putRemoteFile(
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 31.2K bytes
    - Viewed (0)
  6. docs/en/docs/help-fastapi.md

        * Read other ideas, articles, and read about tools I have created.
        * Follow me to read when I publish something new.
    
    ## Tweet about **FastAPI** { #tweet-about-fastapi }
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 14K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle.go

    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceILM) > 0 {
    			e := ""
    			if err != nil {
    				e = err.Error()
    			}
    			globalTrace.Publish(ilmTrace(startTime, duration, oi, event, metadata, e))
    		}
    	}
    }
    
    type expiryTask struct {
    	objInfo ObjectInfo
    	event   lifecycle.Event
    	src     lcEventSrc
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  8. docs/changelogs/changelog_4x.md

    
    ## Version 4.4.0
    
    _2020-02-17_
    
     *  New: Support `canceled()` as an event that can be observed by `EventListener`. This should be
        useful for splitting out canceled calls in metrics.
    
     *  New: Publish a [bill of materials (BOM)][bom] for OkHttp. Depend on this from Gradle or Maven to
        keep all of your OkHttp artifacts on the same version, even if they're declared via transitive
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  9. cmd/admin-handlers.go

    	}, nil)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// Publish bootstrap events that have already occurred before client could subscribe.
    	if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) {
    		go globalBootstrapTracer.Publish(ctx, globalTrace)
    	}
    
    	for _, peer := range peers {
    		if peer == nil {
    			continue
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  10. cmd/erasure-healing.go

    			tr.Custom["disks"] = strconv.Itoa(result.DiskCount)
    			tr.Bytes = result.ObjectSize
    		}
    	}
    	if err != nil {
    		tr.Error = err.Error()
    	}
    	tr.HealResult = result
    	globalTrace.Publish(tr)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
Back to top