- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 322 for deflate (0.14 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt
@Test fun `inflate deflate empty message`() { val deflater = MessageDeflater(false) val inflater = MessageInflater(false) val goldenValue = "".encodeUtf8() val deflated = deflater.deflate(goldenValue) assertThat(deflated).isEqualTo("00".decodeHex()) val inflated = inflater.inflate(deflated) assertThat(inflated).isEqualTo(goldenValue) } @Test fun `inflate deflate with context takeover`() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 06 05:31:00 UTC 2024 - 5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketExtensionsTest.kt
} @Test fun emptyParameters() { assertThat(parse("permessage-deflate;")) .isEqualTo(WebSocketExtensions(perMessageDeflate = true)) } @Test fun repeatedPerMessageDeflate() { assertThat(parse("permessage-deflate, permessage-deflate; server_no_context_takeover")) .isEqualTo( WebSocketExtensions( perMessageDeflate = true, serverNoContextTakeover = true,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* Sec-WebSocket-Extensions: permessage-deflate; client_no_context_takeover * Sec-WebSocket-Extensions: permessage-deflate; server_max_window_bits="15" * Sec-WebSocket-Extensions: permessage-deflate; server_max_window_bits=15 * Sec-WebSocket-Extensions: permessage-deflate; server_no_context_takeover * Sec-WebSocket-Extensions: permessage-deflate; server_no_context_takeover; * client_no_context_takeover
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/MessageDeflater.kt
private val deflatedBytes = Buffer() private val deflater = Deflater( Deflater.DEFAULT_COMPRESSION, // nowrap (omits zlib header): true, ) private val deflaterSink = DeflaterSink(deflatedBytes, deflater) /** Deflates [buffer] in place as described in RFC 7692 section 7.2.1. */ @Throws(IOException::class) fun deflate(buffer: Buffer) { require(deflatedBytes.size == 0L)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-runtime/files/src/main/java/org/gradle/api/internal/file/archive/ZipEntry.java
public interface ZipEntry { /** * The compression method used for an entry */ enum ZipCompressionMethod { /** * The entry is compressed with DEFLATE algorithm. */ DEFLATED, /** * The entry is stored uncompressed. */ STORED, /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:00 UTC 2024 - 2.5K bytes - Viewed (0) -
samples/compare/src/test/kotlin/okhttp3/compare/ApacheHttpClientTest.kt
} val recorded = server.takeRequest() assertThat(recorded.headers["Accept"]).isEqualTo("text/plain") assertThat(recorded.headers["Accept-Encoding"]).isEqualTo("gzip, x-gzip, deflate") assertThat(recorded.headers["Connection"]).isEqualTo("keep-alive") assertThat(recorded.headers["User-Agent"]!!).startsWith("Apache-HttpClient/") }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* structures. * * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is * not terminated. * * Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of * the internal list. */ @JvmStatic
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 4.3K bytes - Viewed (0) -
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) -
dbflute.xml
</target> <target name="download.dbflute" depends="mydbflute.check" unless="mydbflute.exists"> <mkdir dir="${mydbflute.dir}" /> <get dest="${target.dir}/mydbflute.zip"> <url url="${mydbflute.url}" /> </get> <unzip dest="${mydbflute.dir}" src="${target.dir}/mydbflute.zip"> <patternset> <include name="lastaflute-example-waterfront-${branch.name}/mydbflute/dbflute-1.x/**" /> </patternset>
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun May 26 05:59:50 UTC 2024 - 1000 bytes - Viewed (0) -
docs/bucket/replication/delete-replication.sh
aws configure set aws_secret_access_key minioadmin --profile minioadmin aws configure set default.region us-east-1 --profile minioadmin aws s3api --endpoint-url http://localhost:9001 --profile minioadmin delete-object --bucket testbucket --key dir/file --version-id "$versionId" ./mc ls -r --versions myminio1/testbucket >/tmp/myminio1.txt ./mc ls -r --versions myminio2/testbucket >/tmp/myminio2.txt
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 3K bytes - Viewed (0)