Search Options

Display Count
Sort
Preferred Language
Advanced Search

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

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

  1. android/guava/src/com/google/common/hash/AbstractByteHasher.java

    import java.nio.ByteBuffer;
    import java.nio.ByteOrder;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Abstract {@link Hasher} that handles converting primitives to bytes using a scratch {@code
     * ByteBuffer} and streams all bytes to a sink to compute the hash.
     *
     * @author Colin Decker
     */
    abstract class AbstractByteHasher extends AbstractHasher {
      private @Nullable ByteBuffer scratch;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 12:40:17 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

         */
        fun newSink(index: Int): Sink {
          synchronized(this@DiskLruCache) {
            check(!done)
            if (entry.currentEditor != this) {
              return blackholeSink()
            }
            if (!entry.readable) {
              written!![index] = true
            }
            val dirtyFile = entry.dirtyFiles[index]
            val sink: Sink
            try {
              sink = fileSystem.sink(dirtyFile)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 34.7K bytes
    - Click Count (0)
  3. samples/guide/src/main/java/okhttp3/recipes/kt/PostStreaming.kt

        val requestBody =
          object : RequestBody() {
            override fun contentType() = MEDIA_TYPE_MARKDOWN
    
            override fun writeTo(sink: BufferedSink) {
              sink.writeUtf8("Numbers\n")
              sink.writeUtf8("-------\n")
              for (i in 2..997) {
                sink.writeUtf8(String.format(" * $i = ${factor(i)}\n"))
              }
            }
    
            private fun factor(n: Int): String {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockResponseBody.kt

     * called by readers.
     */
    public interface MockResponseBody {
      /** The length of this response in bytes, or -1 if unknown. */
      public val contentLength: Long
    
      @Throws(IOException::class)
      public fun writeTo(sink: BufferedSink)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jun 14 16:09:26 GMT 2025
    - 1K bytes
    - Click Count (0)
  5. 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)
  6. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

            if (closed) return
            try {
              super.close()
            } finally {
              closedLatch.countDown()
            }
          }
        }.buffer()
    
      override val sink: BufferedSink =
        object : ForwardingSink(delegate.sink) {
          private var closed = false
    
          override fun close() {
            if (closed) return
            try {
              super.close()
            } finally {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. android/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)
  10. android/guava-tests/test/com/google/common/io/TestCharSink.java

    import java.io.FilterWriter;
    import java.io.IOException;
    import java.io.OutputStreamWriter;
    import java.io.Writer;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * A char sink for testing that has configurable behavior.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public class TestCharSink extends CharSink implements TestStreamSupplier {
    
      private final TestByteSink byteSink;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 2.1K bytes
    - Click Count (0)
Back to Top