- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for sendResponses (0.29 sec)
-
internal/grid/muxserver.go
for in := range inbound { 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
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 23.9K 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()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0)