- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for readRequests (0.14 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid // read initial pod add readRequest(t, ztunClient) sendAck(ztunClient) // read snapshot sent m, fds := readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil { panic("expected snapshot sent") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0) -
platforms/core-runtime/internal-instrumentation-processor/src/main/java/org/gradle/internal/instrumentation/processor/modelreader/api/CallInterceptionRequestReaderFromAnnotatedMethod.java
import java.util.Collection; public interface CallInterceptionRequestReaderFromAnnotatedMethod extends CallInterceptionRequestReader<ExecutableElement> { @Override Collection<Result> readRequest(ExecutableElement input);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 972 bytes - Viewed (0) -
platforms/core-runtime/internal-instrumentation-processor/src/main/java/org/gradle/internal/instrumentation/processor/modelreader/api/CallInterceptionRequestReader.java
import org.gradle.internal.instrumentation.model.CallInterceptionRequest; import java.util.Collection; public interface CallInterceptionRequestReader<T> { Collection<Result> readRequest(T input); interface Result { class Success implements Result { private final CallInterceptionRequest request; public Success(CallInterceptionRequest request) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Oct 02 15:44:14 UTC 2023 - 1.4K bytes - Viewed (0) -
src/net/http/httptest/httptest.go
// the NewRequest function in the net/http package. func NewRequestWithContext(ctx context.Context, method, target string, body io.Reader) *http.Request { if method == "" { method = "GET" } req, err := http.ReadRequest(bufio.NewReader(strings.NewReader(method + " " + target + " HTTP/1.0\r\n\r\n"))) if err != nil { panic("invalid NewRequest arguments; " + err.Error()) } req = req.WithContext(ctx)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 18:09:14 UTC 2024 - 2.6K bytes - Viewed (0) -
src/net/http/httputil/dump.go
// goroutine exits if t.RoundTrip returns an error. // See golang.org/issue/32571. quitReadCh := make(chan struct{}) // Wait for the request before replying with a dummy response: go func() { req, err := http.ReadRequest(bufio.NewReader(pr)) if err == nil { // Ensure all the body is read; otherwise // we'll get a partial dump. io.Copy(io.Discard, req.Body) req.Body.Close() } select {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9.3K bytes - Viewed (0)