Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 2,241 for Sink (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava-tests/test/com/google/common/io/TestByteSink.java

    import com.google.common.collect.ImmutableSet;
    import java.io.ByteArrayOutputStream;
    import java.io.IOException;
    import java.io.OutputStream;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * A byte sink for testing that has configurable behavior.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public class TestByteSink extends ByteSink implements TestStreamSupplier {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  2. okhttp/src/commonTest/kotlin/okhttp3/internal/IsProbablyUtf8Test.kt

      @Test fun doesNotReadEntireSource() {
        val unlimitedSource =
          object : Source {
            override fun read(
              sink: Buffer,
              byteCount: Long,
            ): Long {
              sink.writeUtf8("a".repeat(byteCount.toInt()))
              return byteCount
            }
    
            override fun close() {
            }
    
            override fun timeout() = Timeout.NONE
          }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Oct 06 22:47:06 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt

            .method("POST", AsyncRequestBody())
            .build()
        val call = client.newCall(request)
        call.execute().use { response ->
          val sink = (request.body as AsyncRequestBody?)!!.takeSink()
          sink.writeUtf8("hey\n")
          sink.writeUtf8("whats going on\n")
          sink.close()
        }
        body.awaitSuccess()
      }
    
      @Test
      fun requestBodyEndsAfterResponseBody() {
        enableProtocol(Protocol.HTTP_2)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 25.8K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/MultipartBodyTest.kt

        class StreamingBody(
          private val body: String,
        ) : RequestBody() {
          override fun contentType(): MediaType? = null
    
          @Throws(IOException::class)
          override fun writeTo(sink: BufferedSink) {
            sink.writeUtf8(body)
          }
        }
    
        val expected =
          """
          |--123
          |
          |Quick
          |--123
          |
          |Brown
          |--123
          |
          |Fox
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

            private var cacheRequestClosed = false
    
            @Throws(IOException::class)
            override fun read(
              sink: Buffer,
              byteCount: Long,
            ): Long {
              val bytesRead: Long
              try {
                bytesRead = source.read(sink, byteCount)
              } catch (e: IOException) {
                if (!cacheRequestClosed) {
                  cacheRequestClosed = true
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 10.3K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/io/package-info.java

    /**
     * Utility methods and classes for I/O; for example input streams, output streams, readers, writers,
     * and files.
     *
     * <p>At the core of this package are the Source/Sink types: {@link ByteSource ByteSource}, {@link
     * CharSource CharSource}, {@link ByteSink ByteSink} and {@link CharSink CharSink}. They are
     * factories for I/O streams that provide many convenience methods that handle both opening and
     * closing streams for you.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 14:50:24 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt

              .post(
                object : RequestBody() {
                  override fun contentType() = null
    
                  override fun writeTo(sink: BufferedSink) {
                    for (i in 0..9) {
                      sink.writeByte(0)
                      sink.flush()
                      sleep(100)
                    }
                    fail("Expected connection to be closed")
                  }
                },
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 18:33:48 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/UnreadableResponseBody.kt

    ) : ResponseBody(),
      Source {
      override fun contentType() = mediaType
    
      override fun contentLength() = contentLength
    
      override fun source() = buffer()
    
      override fun read(
        sink: Buffer,
        byteCount: Long,
      ): Long =
        throw IllegalStateException(
          """
          |Unreadable ResponseBody! These Response objects have bodies that are stripped:
          | * Response.cacheResponse
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 15:19:53 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Huffman.kt

          while (accumulatorBitCount >= 8) {
            accumulatorBitCount -= 8
            sink.writeByte((accumulator shr accumulatorBitCount).toInt())
          }
        }
    
        if (accumulatorBitCount > 0) {
          accumulator = accumulator shl (8 - accumulatorBitCount)
          accumulator = accumulator or (0xffL ushr accumulatorBitCount)
          sink.writeByte(accumulator.toInt())
        }
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 11K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/HttpUpgradesTest.kt

            val socket = response.socket!!
            socket.sink.buffer().use { sink ->
              socket.source.buffer().use { source ->
                sink.writeUtf8("client says hello\n")
                sink.flush()
    
                assertThat(source.readUtf8Line()).isEqualTo("server says hello")
    
                sink.writeUtf8("client says goodbye\n")
                sink.flush()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 08 21:07:01 GMT 2026
    - 9.7K bytes
    - Click Count (0)
Back to Top