- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for setBody (0.05 seconds)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
call.execute() } } @Test fun interruptReadingResponseBody() { val responseBodySize = 8 * 1024 * 1024 // 8 MiB. server.enqueue( MockResponse() .setBody(Buffer().write(ByteArray(responseBodySize))) .throttleBody((64 * 1024).toLong(), 125, TimeUnit.MILLISECONDS), ) // 500 Kbps server.start() val call = client.newCall( Request
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 6.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt
} internal enum class TransferKind { CHUNKED { override fun setBody( response: MockResponse.Builder, content: Buffer, chunkSize: Int, ) { response.chunkedBody(content, chunkSize) } }, FIXED_LENGTH { override fun setBody( response: MockResponse.Builder, content: Buffer, chunkSize: Int,Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Oct 03 17:41:45 GMT 2025 - 116.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
mockResponse.headers = headersOf() mockResponse.trailers = headersOf() mockResponse = mockResponse.removeHeader("") var body: Buffer? = mockResponse.getBody() mockResponse = mockResponse.setBody(Buffer()) mockResponse = mockResponse.setChunkedBody(Buffer(), 0) mockResponse = mockResponse.setChunkedBody("", 0) var socketPolicy: SocketPolicy = mockResponse.socketPolicy
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 47K bytes - Click Count (0) -
internal/rest/client.go
case *bytes.Buffer: req.ContentLength = int64(v.Len()) buf := v.Bytes() req.GetBody = func() (io.ReadCloser, error) { r := bytes.NewReader(buf) return io.NopCloser(r), nil } case *bytes.Reader: req.ContentLength = int64(v.Len()) snapshot := *v req.GetBody = func() (io.ReadCloser, error) { r := snapshot return io.NopCloser(&r), nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
mockwebserver/README.md
RecordedRequest request = server.takeRequest(); assertEquals("POST /v1/chat/send HTTP/1.1", request.getRequestLine()); assertEquals("application/json; charset=utf-8", request.getHeaders().get("Content-Type")); assertEquals("{}", request.getBody().readUtf8()); ``` ### Kotlin ```kotlin val request = server.takeRequest() assertEquals("POST /v1/chat/send HTTP/1.1", request.requestLine)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 21:39:59 GMT 2025 - 8.1K bytes - Click Count (0) -
src/archive/zip/reader_test.go
} }) } } func TestFSWalkBadFile(t *testing.T) { t.Parallel() var buf bytes.Buffer zw := NewWriter(&buf) hdr := &FileHeader{Name: "."} hdr.SetMode(fs.ModeDir | 0o755) w, err := zw.CreateHeader(hdr) if err != nil { t.Fatalf("create zip header: %v", err) } _, err = w.Write([]byte("some data")) if err != nil {
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Oct 17 20:10:27 GMT 2025 - 56.5K bytes - Click Count (0)