Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for mbuf (0.14 sec)

  1. okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt

          return hex.decodeHex().toResponseBody(mediaType)
        }
    
        fun exhaust(reader: Reader): String {
          val builder = StringBuilder()
          val buf = CharArray(10)
          var read: Int
          while (reader.read(buf).also { read = it } != -1) {
            builder.appendRange(buf, 0, read)
          }
          return builder.toString()
        }
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 13K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

                  sink.writeByte('x'.code)
                }
              } else {
                val buf = ByteArray(if (writeKind == WriteKind.SMALL_BUFFERS) 256 else 64 * 1024)
                Arrays.fill(buf, 'x'.code.toByte())
                var i = 0
                while (i < n) {
                  sink.write(buf, 0, Math.min(buf.size, n - i))
                  i += buf.size
                }
              }
            }
          }
        val response =
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 131.7K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

        private val charset: Charset,
      ) : Reader() {
        private var closed: Boolean = false
        private var delegate: Reader? = null
    
        @Throws(IOException::class)
        override fun read(
          cbuf: CharArray,
          off: Int,
          len: Int,
        ): Int {
          if (closed) throw IOException("Stream closed")
    
          val finalDelegate =
            delegate ?: InputStreamReader(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.7K bytes
    - Viewed (0)
  4. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt

        }
    
        val questionCount = buf.readShort().toInt() and 0xffff
        val answerCount = buf.readShort().toInt() and 0xffff
        buf.readShort() // authority record count
        buf.readShort() // additional record count
    
        for (i in 0 until questionCount) {
          skipName(buf) // name
          buf.readShort() // type
          buf.readShort() // class
        }
    
        for (i in 0 until answerCount) {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/HuffmanTest.kt

        for (i in s.indices) {
          assertRoundTrip(s.substring(0, i).encodeUtf8())
        }
        val random = Random(123456789L)
        val buf = ByteArray(4096)
        random.nextBytes(buf)
        assertRoundTrip(buf.toByteString())
      }
    
      private fun assertRoundTrip(data: ByteString) {
        val encodeBuffer = Buffer()
        encode(data, encodeBuffer)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Jan 04 05:32:07 GMT 2024
    - 1.8K bytes
    - Viewed (0)
Back to top