- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 615 for wire (0.25 sec)
-
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt
"Test stories missing, checkout git submodule", ) val newCases = mutableListOf<Case>() for (case in story.cases) { hpackWriter.writeHeaders(case.headersList) newCases += case.copy(wire = bytesOut.readByteString()) } testDecoder(story.copy(cases = newCases)) } companion object { private val RAW_DATA = arrayOf("raw-data") }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
src/net/dnsname_test.go
longDomain := strings.Repeat(char63+".", 5) + "example" for _, tc := range dnsNameTests { ch <- tc } ch <- dnsNameTest{char63 + ".com", true} ch <- dnsNameTest{char64 + ".com", false} // Remember: wire format is two octets longer than presentation // (length octets for the first and [root] last labels). // 253 is fine: ch <- dnsNameTest{longDomain[len(longDomain)-253:], true} // A terminal dot doesn't contribute to length:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2K bytes - Viewed (0) -
src/net/http/httputil/dump.go
// The wire format for https and http are the same, anyway. reqSend := req if req.URL.Scheme == "https" { reqSend = new(http.Request) *reqSend = *req reqSend.URL = new(url.URL) *reqSend.URL = *req.URL reqSend.URL.Scheme = "http" } // Use the actual Transport code to record what we would send // on the wire, but not using TCP. Use a Transport with a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/internal/hub/MessageHubIntegrationTest.groovy
import java.util.concurrent.CountDownLatch import java.util.concurrent.LinkedBlockingQueue @Timeout(60) class MessageHubIntegrationTest extends ConcurrentSpec { final Action<Throwable> errorHandler = Mock() def "can wire two hubs together"() { Dispatch<String> clientHandler = Mock() Dispatch<String> serverHandler = Mock() def server = new Participant() def client = new Participant()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 9K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/dep-man/06-publishing/publishing_signing.adoc
include::sample[dir="snippets/signing/maven-publish/groovy",files="build.gradle[tags=sign-publication]"] ==== This will create a `Sign` task for each publication you specify and wire all `publish__PubName__PublicationTo__RepoName__Repository` tasks to depend on it. Thus, publishing any publication will automatically create and publish the signatures for its artifacts and metadata, as you can see from this output:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.9K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt
private val bytesIn = Buffer() private val hpackReader = Hpack.Reader(bytesIn, 4096) protected fun testDecoder(story: Story) { for (testCase in story.cases) { val encoded = testCase.wire ?: continue bytesIn.write(encoded) hpackReader.readHeaders() assertSetEquals( "seqno=$testCase.seqno", testCase.headersList, hpackReader.getAndResetHeaderList(), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.2K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl-tooling-builders/src/crossVersionTest/groovy/org/gradle/kotlin/dsl/tooling/builders/r60/KotlinDslScriptsModelCrossVersionSpec.groovy
assert singleRequestModels[script].implicitImports == multiRequestsModels[script].implicitImports } } def "multi-scripts model is dehydrated over the wire"() { given: withBuildSrc() buildFileKts << "" when: def model = loadValidatedToolingModel(KotlinDslScriptsModel) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Dec 16 19:10:39 UTC 2023 - 3.7K bytes - Viewed (0) -
platforms/core-runtime/build-state/src/main/java/org/gradle/internal/buildprocess/execution/SessionFailureReportingActionExecutor.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.4K bytes - Viewed (0) -
src/internal/trace/raw/reader.go
// into an event stream. type Reader struct { r *bufio.Reader v version.Version specs []event.Spec } // NewReader creates a new reader for the trace wire format. func NewReader(r io.Reader) (*Reader, error) { br := bufio.NewReader(r) v, err := version.ReadHeader(br) if err != nil { return nil, err } return &Reader{r: br, v: v, specs: v.Specs()}, nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.2K bytes - Viewed (0) -
platforms/core-runtime/build-state/src/main/java/org/gradle/internal/session/CrossBuildSessionState.java
.displayName("cross session services") .parent(parent) .provider(new Services(startParameter)) .build(); // Trigger listener to wire itself in services.get(BuildOperationTrace.class); } public ServiceRegistry getServices() { return services; } @Override public void close() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 3.4K bytes - Viewed (0)