- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for sendResponse (0.51 sec)
-
okhttp/src/test/java/okhttp3/DuplexTest.kt
enableProtocol(Protocol.HTTP_2) val body = MockStreamHandler() .receiveRequest("request A\n") .sendResponse("response B\n") .receiveRequest("request C\n") .sendResponse("response D\n") .receiveRequest("request E\n") .sendResponse("response F\n") .exhaustRequest() .exhaustResponse() server.enqueue( MockResponse.Builder()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0) -
src/net/http/filetransport.go
wroteHeader bool hasContent bool sentResponse bool pw *io.PipeWriter } func (pr *populateResponse) finish() { if !pr.wroteHeader { pr.WriteHeader(500) } if !pr.sentResponse { pr.sendResponse() } pr.pw.Close() } func (pr *populateResponse) sendResponse() { if pr.sentResponse { return } pr.sentResponse = true if pr.hasContent {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
try { stream.requestBody.exhausted() throw AssertionError("expected IOException") } catch (expected: IOException) { } } } @JvmOverloads fun sendResponse( s: String, responseSent: CountDownLatch = CountDownLatch(0), ) = apply { actions += { stream -> stream.responseBody.writeUtf8(s) stream.responseBody.flush() responseSent.countDown()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout_test.go
} }) } func TestTimeout(t *testing.T) { origReallyCrash := runtime.ReallyCrash runtime.ReallyCrash = false defer func() { runtime.ReallyCrash = origReallyCrash }() sendResponse := make(chan string, 1) doPanic := make(chan interface{}, 1) writeErrors := make(chan error, 1) gotPanic := make(chan interface{}, 1) timeout := make(chan time.Time, 1) resp := "test response"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 18.4K bytes - Viewed (0) -
src/net/rpc/server.go
// receives an invalid request. It is never decoded by the client since the Response // contains an error when it is used. var invalidRequest = struct{}{} func (server *Server) sendResponse(sending *sync.Mutex, req *Request, reply any, codec ServerCodec, errmsg string) { resp := server.getResponse() // Encode the response header resp.ServiceMethod = req.ServiceMethod if errmsg != "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
pkg/xds/server.go
} func Send(ctx ConnectionContext, res *discovery.DiscoveryResponse) error { conn := ctx.XdsConnection() sendResponse := func() error { start := time.Now() defer func() { RecordSendTime(time.Since(start)) }() return conn.stream.Send(res) } err := sendResponse() if err == nil { if res.Nonce != "" && !strings.HasPrefix(res.TypeUrl, model.DebugType) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
src/net/textproto/pipeline.go
// the request with the given id. func (p *Pipeline) StartResponse(id uint) { p.response.Start(id) } // EndResponse notifies p that the response with the given id has been received // (or, if this is a server, sent). func (p *Pipeline) EndResponse(id uint) { p.response.End(id) } // A sequencer schedules a sequence of numbered events that must
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 08 16:19:51 UTC 2020 - 3K bytes - Viewed (0) -
src/net/textproto/textproto.go
// Cmd returns the id of the command, for use with StartResponse and EndResponse. // // For example, a client might run a HELP command that returns a dot-body // by using: // // id, err := c.Cmd("HELP") // if err != nil { // return nil, err // } // // c.StartResponse(id) // defer c.EndResponse(id) // // if _, _, err = c.ReadCodeLine(110); err != nil { // return nil, err // }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3.7K bytes - Viewed (0) -
internal/grid/muxserver.go
case <-m.ctx.Done(): return case handlerIn <- in: m.send(message{Op: OpUnblockClMux, MuxID: m.ID, Flags: c.baseFlags}) } } } } // sendResponses will send responses to the client. func (m *muxServer) sendResponses(ctx context.Context, toSend <-chan []byte, c *Connection, handlerErr *atomic.Pointer[RemoteErr], outBlock <-chan struct{}) { for { // Process outgoing message. var payload []byte
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/net/http/httputil/persist.go
// Ensure ordered execution of Reads and Writes id := sc.pipe.Next() sc.pipe.StartRequest(id) defer func() { sc.pipe.EndRequest(id) if req == nil { sc.pipe.StartResponse(id) sc.pipe.EndResponse(id) } else { // Remember the pipeline id of this request sc.mu.Lock() sc.pipereq[req] = id sc.mu.Unlock() } }() sc.mu.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0)