Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 74 for WriteTo (0.26 sec)

  1. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/GenerateIdnaMappingTableCode.kt

    import java.io.File
    import okio.FileSystem
    import okio.Path.Companion.toPath
    
    fun main(vararg args: String) {
      val data = loadIdnaMappingTableData()
      val file = generateMappingTableFile(data)
      file.writeTo(File(args[0]))
    }
    
    fun loadIdnaMappingTableData(): IdnaMappingTableData {
      val path = "/okhttp3/internal/idna/IdnaMappingTable.txt".toPath()
      val table =
        FileSystem.RESOURCES.read(path) {
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

          client.newCall(
            Request.Builder()
              .url(server.url("/"))
              .post(
                object : RequestBody() {
                  override fun contentType() = null
    
                  override fun writeTo(sink: BufferedSink) {
                    for (i in 0..9) {
                      sink.writeByte(0)
                      sink.flush()
                      sleep(100)
                    }
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  3. cmd/utils.go

    			runtime.GC()
    			var buf bytes.Buffer
    			err := pprof.Lookup("heap").WriteTo(&buf, 0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerBlock:
    		runtime.SetBlockProfileRate(100)
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("block").WriteTo(&buf, 0)
    			runtime.SetBlockProfileRate(0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerMutex:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 31.3K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

                  override fun contentType(): MediaType? {
                    return null
                  }
    
                  @Throws(
                    IOException::class,
                  )
                  override fun writeTo(sink: BufferedSink) {
                    for (i in 0..9) {
                      sink.writeByte(0)
                      sink.flush()
                      sleep(100)
                    }
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  5. src/bytes/buffer.go

    	copy(b2, b)
    	return b2[:len(b)]
    }
    
    // WriteTo writes data to w until the buffer is drained or an error occurs.
    // The return value n is the number of bytes written; it always fits into an
    // int, but it is int64 to match the io.WriterTo interface. Any error
    // encountered during the write is also returned.
    func (b *Buffer) WriteTo(w io.Writer) (n int64, err error) {
    	b.lastRead = opInvalid
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Oct 13 17:10:31 GMT 2023
    - 15.7K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/MultipartBody.kt

        var result = contentLength
        if (result == -1L) {
          result = writeOrCountBytes(null, true)
          contentLength = result
        }
        return result
      }
    
      @Throws(IOException::class)
      override fun writeTo(sink: BufferedSink) {
        writeOrCountBytes(sink, false)
      }
    
      /**
       * Either writes this request to [sink] or measures its content length. We have one method do
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/FormBody.kt

      override fun contentType(): MediaType = CONTENT_TYPE
    
      override fun contentLength(): Long = writeOrCountBytes(null, true)
    
      @Throws(IOException::class)
      override fun writeTo(sink: BufferedSink) {
        writeOrCountBytes(sink, false)
      }
    
      /**
       * Either writes this request to [sink] or measures its content length. We have one method
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  8. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

            } else if (requestBody.isOneShot()) {
              logger.log("--> END ${request.method} (one-shot body omitted)")
            } else {
              var buffer = Buffer()
              requestBody.writeTo(buffer)
    
              var gzippedLength: Long? = null
              if ("gzip".equals(headers["Content-Encoding"], ignoreCase = true)) {
                gzippedLength = buffer.size
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 06 09:14:38 GMT 2024
    - 11.2K bytes
    - Viewed (1)
  9. src/bufio/bufio_test.go

    	br := NewReader(strings.NewReader("example"))
    	br.WriteTo(io.Discard)
    	if err := br.UnreadRune(); err == nil {
    		t.Error("UnreadRune didn't fail after WriteTo")
    	}
    }
    
    func TestNoUnreadByteAfterWriteTo(t *testing.T) {
    	br := NewReader(strings.NewReader("example"))
    	br.WriteTo(io.Discard)
    	if err := br.UnreadByte(); err == nil {
    		t.Error("UnreadByte didn't fail after WriteTo")
    	}
    }
    
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Feb 10 18:56:01 GMT 2023
    - 51.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CallTest.kt

        // Call 1: set a deadline on the request body.
        val requestBody1: RequestBody =
          object : RequestBody() {
            override fun contentType(): MediaType = "text/plain".toMediaType()
    
            override fun writeTo(sink: BufferedSink) {
              sink.writeUtf8("abc")
              sink.timeout().deadline(5, TimeUnit.SECONDS)
            }
          }
        val request1 =
          Request.Builder()
            .url(server.url("/"))
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
Back to top