Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for setBody (0.05 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to Top