Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for Observer (0.08 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

          )
        peer.sendFrame().headers(true, 2, expectedResponseHeaders)
        peer.sendFrame().data(true, 3, data(0), 0)
        peer.play()
        val observer = RecordingPushObserver()
    
        // Play it back.
        val connection = connect(peer, observer, Http2Connection.Listener.REFUSE_INCOMING_STREAMS)
        val client = connection.newStream(headerEntries("b", "banana"), false)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    							continue
    						}
    					} else {
    						r = io.NopCloser(bytes.NewBuffer([]byte{}))
    					}
    					// Keep disk path instead of ID, to ensure that the downloaded zip file can be
    					// easily automated with `minio server hostname{1...n}/disk{1...m}`.
    					err = fn(r, disk.Hostname(), disk.Endpoint().Path, pathJoin(volume, si.Name), si)
    					r.Close()
    					if err != nil {
    						return err
    					}
    				}
    			}
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	subrouter.Methods(http.MethodPost).Path(peerRESTVersionPrefix + peerRESTMethodDevNull).HandlerFunc(h(server.DevNull))
    
    	logger.FatalIf(consoleLogRPC.RegisterNoInput(gm, server.ConsoleLogHandler), "unable to register handler")
    	logger.FatalIf(deleteBucketMetadataRPC.Register(gm, server.DeleteBucketMetadataHandler), "unable to register handler")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

      @get:JvmName("dispatcher")
      val dispatcher: Dispatcher = builder.dispatcher
    
      /**
       * Returns an immutable list of interceptors that observe the full span of each call: from before
       * the connection is established (if any) until after the response source is selected (either the
       * origin server, cache, or both).
       */
      @get:JvmName("interceptors")
      val interceptors: List<Interceptor> =
        builder.interceptors.toImmutableList()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

      fun multipleDnsLookupsForSingleCall() {
        server.enqueue(
          MockResponse
            .Builder()
            .code(301)
            .setHeader("Location", "http://www.fakeurl:" + server.port)
            .build(),
        )
        server.enqueue(MockResponse())
        val dns = FakeDns()
        dns["fakeurl"] = client.dns.lookup(server.hostName)
        dns["www.fakeurl"] = client.dns.lookup(server.hostName)
        client =
          client
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 60.4K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/grafana/minio-dashboard.json

                "uid": "${DS_PROMETHEUS}"
              },
              "exemplar": true,
              "expr": "sum by (server) (rate(minio_s3_traffic_received_bytes{job=~\"$scrape_jobs\"}[$__rate_interval]))",
              "interval": "1m",
              "intervalFactor": 2,
              "legendFormat": "Data Received [{{server}}]",
              "refId": "A"
            }
          ],
          "title": "S3 API Ingress Rate ",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 04 01:46:49 UTC 2025
    - 93.1K bytes
    - Viewed (0)
  7. docs/bucket/notifications/README.md

    ```
    
    MinIO server also supports [NATS Streaming mode](http://nats.io/documentation/streaming/nats-streaming-intro/) that offers additional functionality like `At-least-once-delivery`, and `Publisher rate limiting`. To configure MinIO server to send notifications to NATS Streaming server, update the MinIO server configuration file as follows:
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

      @ArgumentsSource(ProtocolParamProvider::class)
      fun connectionReuse(protocol: Protocol) {
        setUp(protocol)
        server.enqueue(MockResponse(body = "ABCDEF"))
        server.enqueue(MockResponse(body = "GHIJKL"))
        val call1 = client.newCall(Request(server.url("/r1")))
        val call2 = client.newCall(Request(server.url("/r1")))
        val response1 = call1.execute()
        val response2 = call2.execute()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  9. src/main/webapp/js/bootstrap.min.js

    utedStyle(this._element).overflowY?null:this._element,this._activeTarget=null,this._observer=null,this._previousScrollData={visibleEntryTop:0,parentScrollTop:0},this.refresh()}static get Default(){return ze}static get DefaultType(){return He}static get NAME(){return"scrollspy"}refresh(){this._initializeTargetsAndObservables(),this._maybeEnableSmoothScroll(),this._observer?this._observer.disconnect():this._observer=this._getNewObserver();for(const t of this._observableSections.values())this._obse...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Jan 12 06:14:02 UTC 2025
    - 58.9K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/HttpUrl.kt

     *
     * ### Host
     *
     * The host identifies the webserver that serves the URL's resource. It is either a hostname like
     * `square.com` or `localhost`, an IPv4 address like `192.168.0.1`, or an IPv6 address like `::1`.
     *
     * Usually a webserver is reachable with multiple identifiers: its IP addresses, registered
     * domain names, and even `localhost` when connecting from the server itself. Each of a web server's
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 63.5K bytes
    - Viewed (0)
Back to top