Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 32 for Writer (0.14 sec)

  1. okhttp/src/main/kotlin/okhttp3/RequestBody.kt

       * use this feature.
       *
       * ### Duplex APIs
       *
       * With regular request bodies it is not legal to write bytes to the sink passed to
       * [RequestBody.writeTo] after that method returns. For duplex requests bodies that condition is
       * lifted. Such writes occur on an application-provided thread and may occur concurrently with
       * reads of the [ResponseBody]. For duplex request bodies, [writeTo] should return
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Jan 25 14:41:37 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/FormBody.kt

      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
       * do double-duty to make sure the counting and content are consistent, particularly when it comes
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/MultipartBody.kt

          val body = part.body
    
          sink!!.write(DASHDASH)
          sink.write(boundaryByteString)
          sink.write(CRLF)
    
          if (headers != null) {
            for (h in 0 until headers.size) {
              sink.writeUtf8(headers.name(h))
                .write(COLONSPACE)
                .writeUtf8(headers.value(h))
                .write(CRLF)
            }
          }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

      private val messageBuffer = Buffer()
    
      /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
      private val sinkBuffer: Buffer = sink.buffer
      private var writerClosed = false
    
      /** Lazily initialized on first use. */
      private var messageDeflater: MessageDeflater? = null
    
      // Masks are only a concern for client writers.
      private val maskKey: ByteArray? = if (isClient) ByteArray(4) else null
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        // Verify the peer's settings were read and applied.
        assertThat(connection.peerSettings.headerTableSize).isEqualTo(0)
        val writer = connection.writer
        assertThat(writer.hpackWriter.dynamicTableByteCount).isEqualTo(0)
        assertThat(writer.hpackWriter.headerTableSizeSetting).isEqualTo(0)
      }
    
      @Test fun peerHttp2ClientDisablesPush() {
        val client = false // Peer is client, so we are server.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 75.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

      private lateinit var server: MockWebServer
      private lateinit var client: OkHttpClient
    
      @BeforeEach
      fun setUp() {
        // Sockets on some platforms can have large buffers that mean writes do not block when
        // required. These socket factories explicitly set the buffer sizes on sockets created.
        server = MockWebServer()
        server.serverSocketFactory =
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        }
      }
    
      /** A sink that writes outgoing data frames of a stream. This class is not thread safe. */
      internal inner class FramingSink(
        /** True if either side has cleanly shut down this stream. We shall send no more bytes. */
        var finished: Boolean = false,
      ) : Sink {
        /**
         * Buffer of outgoing data. This batches writes of small writes into this sink as larges frames
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  8. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

      private val messageFrameBuffer = Buffer()
    
      /** Lazily initialized on first use. */
      private var messageInflater: MessageInflater? = null
    
      // Masks are only a concern for server writers.
      private val maskKey: ByteArray? = if (isClient) null else ByteArray(4)
      private val maskCursor: Buffer.UnsafeCursor? = if (isClient) null else Buffer.UnsafeCursor()
    
      interface FrameCallback {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.8K bytes
    - Viewed (0)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

              return false
            }
    
            if (!dispatcher.peek().inTunnel) return true // No more tunnel requests.
          }
        }
    
        /**
         * Reads a request and writes its response. Returns true if further calls should be attempted
         * on the socket.
         */
        @Throws(IOException::class, InterruptedException::class)
        private fun processOneRequest(
          socket: Socket,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 37.4K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CacheTest.kt

            .code(HttpURLConnection.HTTP_NOT_MODIFIED)
            .build(),
        )
        server.enqueue(
          MockResponse.Builder()
            .body("B")
            .build(),
        )
    
        // A cache miss writes the cache.
        val t0 = System.currentTimeMillis()
        val response1 = get(server.url("/a"))
        assertThat(response1.body.string()).isEqualTo("A")
        assertThat(response1.header("Allow")).isNull()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 108.6K bytes
    - Viewed (0)
Back to top