Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 908 for writeTo (0.67 seconds)

  1. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

          override fun contentLength(): Long = if (chunked) -1L else size
    
          override fun writeTo(sink: BufferedSink) {
            var count = 0
            while (count < size) {
              sink.write(buffer, 0, Math.min(size - count, writeSize.toLong()).toInt())
              count += writeSize
            }
          }
        }
      }
    
      @Test
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 147.4K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

                  override fun contentLength(): Long = postBytes.size.toLong()
    
                  override fun writeTo(sink: BufferedSink) {
                    sink.write(postBytes) // push bytes into the stream's buffer
                    sink.flush() // Http2Connection.writeData subject to write window
                    sink.close() // Http2Connection.writeData empty frame
                  }
                },
            ),
          )
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 67.4K bytes
    - Click Count (0)
  3. guava/src/com/google/common/math/Stats.java

       * versions.
       */
      public byte[] toByteArray() {
        ByteBuffer buff = ByteBuffer.allocate(BYTES).order(ByteOrder.LITTLE_ENDIAN);
        writeTo(buff);
        return buff.array();
      }
    
      /**
       * Writes to the given {@link ByteBuffer} a byte representation of this instance.
       *
       * <p><b>Note:</b> No guarantees are made regarding stability of the representation between
       * versions.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 24.8K bytes
    - Click Count (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

              policy = response,
              socketEffect = response.onResponseBody,
              expectedByteCount = body.contentLength,
              socket = socket,
            ).buffer()
        body.writeTo(responseBodySink)
        responseBodySink.emit()
    
        socket.sleepWhileOpen(response.trailersDelayNanos)
        if ("chunked".equals(response.headers["Transfer-Encoding"], ignoreCase = true)) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 02 20:36:00 GMT 2025
    - 40.3K bytes
    - Click Count (0)
  5. mockwebserver/api/mockwebserver3.api

    }
    
    public abstract interface class mockwebserver3/MockResponseBody {
    	public abstract fun getContentLength ()J
    	public abstract fun writeTo (Lokio/BufferedSink;)V
    }
    
    public final class mockwebserver3/MockWebServer : java/io/Closeable {
    	public fun <init> ()V
    	public fun close ()V
    	public final fun enqueue (Lmockwebserver3/MockResponse;)V
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt

            append(" \\\n  -H ${"Content-Type: $contentType".shellEscape()}")
          }
    
          // Append body if present.
          if (includeBody && body != null) {
            val bodyBuffer = Buffer()
            body.writeTo(bodyBuffer)
    
            if (bodyBuffer.isProbablyUtf8()) {
              append(" \\\n  --data ${bodyBuffer.readUtf8().shellEscape()}")
            } else {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Oct 30 13:46:58 GMT 2025
    - 14.7K bytes
    - Click Count (1)
  7. okhttp/api/jvm/okhttp.api

    	public final fun encodedValue (I)Ljava/lang/String;
    	public final fun name (I)Ljava/lang/String;
    	public final fun size ()I
    	public final fun value (I)Ljava/lang/String;
    	public fun writeTo (Lokio/BufferedSink;)V
    }
    
    public final class okhttp3/FormBody$Builder {
    	public fun <init> ()V
    	public fun <init> (Ljava/nio/charset/Charset;)V
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 70.2K bytes
    - Click Count (0)
  8. src/bytes/example_test.go

    	buf := bytes.Buffer{}
    	buf.Write([]byte{'h', 'e', 'l', 'l', 'o', ' ', 'w', 'o', 'r', 'l', 'd'})
    	os.Stdout.Write(buf.Bytes())
    	// Output: hello world
    }
    
    func ExampleBuffer_AvailableBuffer() {
    	var buf bytes.Buffer
    	for i := 0; i < 4; i++ {
    		b := buf.AvailableBuffer()
    		b = strconv.AppendInt(b, int64(i), 10)
    		b = append(b, ' ')
    		buf.Write(b)
    	}
    	os.Stdout.Write(buf.Bytes())
    	// Output: 0 1 2 3
    }
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon May 12 16:07:54 GMT 2025
    - 16.5K bytes
    - Click Count (0)
  9. api/go1.8.txt

    pkg net/http, var ErrServerClosed error
    pkg net/http, var NoBody noBody
    pkg net/mail, func ParseDate(string) (time.Time, error)
    pkg net, method (*Buffers) Read([]uint8) (int, error)
    pkg net, method (*Buffers) WriteTo(io.Writer) (int64, error)
    pkg net, method (*Resolver) LookupAddr(context.Context, string) ([]string, error)
    pkg net, method (*Resolver) LookupCNAME(context.Context, string) (string, error)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Dec 21 05:25:57 GMT 2016
    - 16.3K bytes
    - Click Count (0)
  10. internal/config/config.go

    			b.WriteString(ep.Value)
    			b.WriteString(KvNewline)
    		}
    	}
    }
    
    // WriteTo writes the string representation of the configuration to the given
    // builder. When off is true, adds a comment character before the config system
    // output. It also ignores values when empty and deprecated.
    func (cs *SubsysInfo) WriteTo(b *strings.Builder, off bool) {
    	cs.AddEnvString(b)
    	if off {
    		b.WriteString(KvComment)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 37.7K bytes
    - Click Count (0)
Back to Top