- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 394 for trackers (0.23 sec)
-
platforms/core-configuration/input-tracking/src/test/groovy/org/gradle/internal/configuration/inputs/AbstractAccessTrackingMapTest.groovy
def "get(null) is not tracked and throws"() { when: getMapUnderTestToRead().get(null) then: thrown(NullPointerException) 0 * onAccess._ } def "getOrDefault(null) is not tracked and throws"() { when: getMapUnderTestToRead().getOrDefault(null, "defaultValue")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Nov 11 00:37:04 UTC 2023 - 8.8K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt
@JvmName("-deprecated_getTrailers") @Deprecated( message = "moved to var", replaceWith = ReplaceWith(expression = "trailers"), level = DeprecationLevel.ERROR, ) fun getTrailers(): Headers = trailers fun setTrailers(trailers: Headers) = apply { this.trailers = trailers } @JvmName("-deprecated_getSocketPolicy") @Deprecated( message = "moved to var",
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.2K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
fun headers(headers: Headers) = apply { this.headers = headers.newBuilder() } /** Sets the trailers and returns this. */ fun trailers(trailers: Headers) = apply { this.trailers = trailers.newBuilder() } /** Sets the socket policy and returns this. */ fun socketPolicy(socketPolicy: SocketPolicy) = apply {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 13.3K bytes - Viewed (0) -
src/internal/trace/oldtrace.go
delete(it.createdPreInit, GoID(ev.Args[0])) case oldtrace.EvGoInSyscall: mappedType = go122.EvGoStatus // In the new tracer, GoStatus with GoSyscall knows what thread the // syscall is on. In the old tracer, EvGoInSyscall doesn't contain that // information and all we can do here is specify NoThread. mappedArgs = timedEventArgs{ev.Args[0], ^uint64(0), uint64(go122.GoSyscall)}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 17.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
if (flushHeaders) { connection.flush() } } fun enqueueTrailers(trailers: Headers) { this.withLock { check(!sink.finished) { "already finished" } require(trailers.size != 0) { "trailers.size() == 0" } this.sink.trailers = trailers } } fun readTimeout(): Timeout = readTimeout fun writeTimeout(): Timeout = writeTimeout
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
tools/packaging/common/envoy_bootstrap.json
"http": { "name": "envoy.tracers.lightstep", "typed_config": { "@type": "type.googleapis.com/envoy.config.trace.v3.LightstepConfig", "collector_cluster": "lightstep", "access_token_file": "{{ .lightstepToken}}" } } } {{- else if .datadog }} , "tracing": { "http": { "name": "envoy.tracers.datadog", "typed_config": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 22.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
private val Request.isChunked: Boolean get() = "chunked".equals(header("Transfer-Encoding"), ignoreCase = true) /** * Received trailers. Null unless the response body uses chunked transfer-encoding and includes * trailers. Undefined until the end of the response body. */ private var trailers: Headers? = null /** Returns true if this connection is closed. */ val isClosed: Boolean get() = state == STATE_CLOSED
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 16.2K bytes - Viewed (0) -
docs/en/docs/advanced/security/http-basic-auth.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Jan 11 14:33:05 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// only the last chunk is zero-sized. if len(cr.buffer) == 0 { if cr.debug { fmt.Println("EOF. Reading Trailers:", cr.trailers) } if cr.trailers != nil { err = cr.readTrailers() if cr.debug { fmt.Println("trailers returned:", err, "now:", cr.trailers) } if err != nil { cr.err = err return 0, err } } cr.err = io.EOF return n, cr.err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
else -> response.headersContentLength() } } override fun openResponseBodySource(response: Response): Source { return stream!!.source } override fun trailers(): Headers { return stream!!.trailers() } override fun cancel() { canceled = true stream?.closeLater(ErrorCode.CANCEL) } companion object { private const val CONNECTION = "connection"
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0)