Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 3,132 for Sink (0.02 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt

            sink.writeByte(ranges[rangesIndex + 2].code or 0x80)
            sink.writeByte(ranges[rangesIndex + 3].code)
          }
          126 -> {
            // Mapped inline to the sequence: [b2, b3a].
            sink.writeByte(ranges[rangesIndex + 2].code)
            sink.writeByte(ranges[rangesIndex + 3].code or 0x80)
          }
          127 -> {
            // Mapped inline to the sequence: [b2a, b3a].
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/hash/HashTestUtils.java

            boolean value = random.nextBoolean();
            for (PrimitiveSink sink : sinks) {
              sink.putBoolean(value);
            }
          }
        },
        PUT_BYTE() {
          @Override
          void performAction(Random random, Iterable<? extends PrimitiveSink> sinks) {
            int value = random.nextInt();
            for (PrimitiveSink sink : sinks) {
              sink.putByte((byte) value);
            }
          }
        },
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/UppercaseRequestInterceptor.kt

            @Throws(IOException::class)
            override fun writeTo(sink: BufferedSink) {
              delegate().writeTo(uppercaseSink(sink).buffer())
            }
          }
        return request
          .newBuilder()
          .method(request.method, uppercaseBody)
          .build()
      }
    
      private fun uppercaseSink(sink: Sink): Sink =
        object : ForwardingSink(sink) {
          @Throws(IOException::class)
          override fun write(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      /**
       * An HTTP body with alternating chunk sizes and chunk bodies. It is the caller's responsibility
       * to buffer chunks; typically by using a buffered sink with this sink.
       */
      private inner class ChunkedSink : Sink {
        private val timeout = ForwardingTimeout(socket.sink.timeout())
        private var closed: Boolean = false
    
        override fun timeout(): Timeout = timeout
    
        override fun write(
          source: Buffer,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  5. android/guava/src/com/google/common/io/ByteSink.java

      protected ByteSink() {}
    
      /**
       * Returns a {@link CharSink} view of this {@code ByteSink} that writes characters to this sink as
       * bytes encoded with the given {@link Charset charset}.
       */
      public CharSink asCharSink(Charset charset) {
        return new AsCharSink(charset);
      }
    
      /**
       * Opens a new {@link OutputStream} for writing to this sink. This method returns a new,
       * independent stream each time it is called.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/io/ByteSink.java

      protected ByteSink() {}
    
      /**
       * Returns a {@link CharSink} view of this {@code ByteSink} that writes characters to this sink as
       * bytes encoded with the given {@link Charset charset}.
       */
      public CharSink asCharSink(Charset charset) {
        return new AsCharSink(charset);
      }
    
      /**
       * Opens a new {@link OutputStream} for writing to this sink. This method returns a new,
       * independent stream each time it is called.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

        }
      }
    
      /** A sink that writes outgoing data frames of a stream. This class is not thread safe. */
      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
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

      private val isClient: Boolean,
      val sink: BufferedSink,
      val random: Random,
      private val perMessageDeflate: Boolean,
      private val noContextTakeover: Boolean,
      private val minimumDeflateSize: Long,
    ) : Closeable {
      /** This holds outbound data for compression and masking. */
      private val messageBuffer = Buffer()
    
      /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 6K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

        fun writeTo(editor: DiskLruCache.Editor) {
          editor.newSink(ENTRY_METADATA).buffer().use { sink ->
            sink.writeUtf8(url.toString()).writeByte('\n'.code)
            sink.writeUtf8(requestMethod).writeByte('\n'.code)
            sink.writeDecimalLong(varyHeaders.size.toLong()).writeByte('\n'.code)
            for (i in 0 until varyHeaders.size) {
              sink
                .writeUtf8(varyHeaders.name(i))
                .writeUtf8(": ")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 17:41:45 UTC 2025
    - 26.8K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt

      /**
       * Returns the number of bytes that will be written to sink in a call to [writeTo],
       * or -1 if that count is unknown.
       */
      @Throws(IOException::class)
      open fun contentLength(): Long = -1L
    
      /** Writes the content of this request to [sink]. */
      @Throws(IOException::class)
      abstract fun writeTo(sink: BufferedSink)
    
      /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 14:16:29 UTC 2025
    - 9.3K bytes
    - Viewed (0)
Back to top