- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,307 for deflate (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
if (perMessageDeflate && data.size >= minimumDeflateSize) { val messageDeflater = this.messageDeflater ?: MessageDeflater(noContextTakeover).also { this.messageDeflater = it } messageDeflater.deflate(messageBuffer) b0 = b0 or B0_FLAG_RSV1 } val dataSize = messageBuffer.size sinkBuffer.writeByte(b0) var b1 = 0 if (isClient) { b1 = b1 or B1_FLAG_MASK }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.9K bytes - Viewed (0) -
src/cmd/distpack/pack.go
} }() zw := zip.NewWriter(out) zw.RegisterCompressor(zip.Deflate, func(out io.Writer) (io.WriteCloser, error) { return flate.NewWriter(out, flate.BestCompression) }) for _, f = range a.Files { h := check(zip.FileInfoHeader(f.Info())) h.Name = f.Name h.Method = zip.Deflate w := check(zw.CreateHeader(h)) r := check(os.Open(f.Src)) check(io.Copy(w, r))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 10.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
client.listener.assertTextMessage(message) } @Test fun messagesCompressedWhenConfigured() { val headers = headersOf("Sec-WebSocket-Extensions", "permessage-deflate") client.initWebSocket(random, responseHeaders = headers) server.initWebSocket(random, responseHeaders = headers) val message = repeat('a', RealWebSocket.DEFAULT_MINIMUM_DEFLATE_SIZE.toInt())
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
src/net/http/requestwrite_test.go
ProtoMinor: 1, Header: Header{ "Accept": {"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8"}, "Accept-Charset": {"ISO-8859-1,utf-8;q=0.7,*;q=0.7"}, "Accept-Encoding": {"gzip,deflate"}, "Accept-Language": {"en-us,en;q=0.5"}, "Keep-Alive": {"300"}, "Proxy-Connection": {"keep-alive"}, "User-Agent": {"Fake"}, }, Body: nil, Close: false,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 07 01:07:32 UTC 2022 - 23.3K bytes - Viewed (0) -
src/compress/flate/example_test.go
"Documentation is for users.\n", } var r strings.Reader var b bytes.Buffer buf := make([]byte, 32<<10) zw, err := flate.NewWriter(nil, flate.DefaultCompression) if err != nil { log.Fatal(err) } zr := flate.NewReader(nil) for _, s := range proverbs { r.Reset(s) b.Reset() // Reset the compressor and encode from some input stream. zw.Reset(&b)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Nov 12 18:42:35 UTC 2016 - 6.5K bytes - Viewed (0) -
src/compress/flate/deflate_test.go
} mm++ if mm == 10 { t.Fatal("Stopping") } } } t.Logf("got %d bytes", len(out1)) } // TestBestSpeed tests that round-tripping through deflate and then inflate // recovers the original input. The Write sizes are near the thresholds in the // compressor.encSpeed method (0, 16, 128), as well as near maxStoreBlockSize // (65535). func TestBestSpeed(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/transport.go
} gzw := gzip.NewWriter(writer) defer gzw.Close() writer = gzw case "deflate": var err error reader = flate.NewReader(reader) flw, err := flate.NewWriter(writer, flate.BestCompression) if err != nil { return nil, fmt.Errorf("errorf making flate writer: %v", err) } defer func() { flw.Close() flw.Flush() }() writer = flw case "":
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 8.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/transport_test.go
}, }, { encodeType: "deflate", writer: func(ept string) *http.Response { flw, _ := flate.NewWriter(flatebuf, flate.BestCompression) defer flw.Close() flw.Write([]byte(ept)) flw.Flush() return &http.Response{ Body: io.NopCloser(flatebuf), } }, reader: func(rep *http.Response) string { reader := flate.NewReader(rep.Body) s, _ := io.ReadAll(reader)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 13.8K bytes - Viewed (0) -
cmd/metacache-entries_test.go
"src/compress/bzip2/testdata/random.data.bz2", "src/compress/flate/deflate.go", "src/compress/flate/deflate_test.go", "src/compress/flate/deflatefast.go", "src/compress/flate/dict_decoder.go", "src/compress/flate/dict_decoder_test.go", "src/compress/flate/example_test.go", "src/compress/flate/flate_test.go", "src/compress/flate/huffman_bit_writer.go", "src/compress/flate/huffman_bit_writer_test.go", "src/compress/flate/huffman_code.go", "src/compress/flate/inflate.go", "src/compress/flate/inflate_test.go",...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 31.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Hpack.kt
Header(RESPONSE_STATUS, "400"), Header(RESPONSE_STATUS, "404"), Header(RESPONSE_STATUS, "500"), Header("accept-charset", ""), Header("accept-encoding", "gzip, deflate"), Header("accept-language", ""), Header("accept-ranges", ""), Header("accept", ""), Header("access-control-allow-origin", ""), Header("age", ""), Header("allow", ""),
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 22.5K bytes - Viewed (0)