- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 359 for Messages (0.4 sec)
-
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* that enqueued messages were not transmitted. */ fun queueSize(): Long /** * Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`) * message. * * This method returns true if the message was enqueued. Messages that would overflow the outgoing * message buffer will be rejected and trigger a [graceful shutdown][close] of this web socket.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordedResponse.kt
} fun assertFailure(vararg messages: String) = apply { assertThat(failure, "No failure found").isNotNull() assertThat(messages).contains(failure!!.message) } fun assertFailureMatches(vararg patterns: String) = apply { val message = failure!!.message!! assertThat( patterns.firstOrNull { pattern -> message.matches(pattern.toRegex()) },
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
if (verbose) { println(record.message) println(record.parameters[0]) } // JSSE logs additional messages as parameters that are not referenced in the log message. val parameter = parameters[0] as String if (message == "Produced ClientHello handshake message") {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.7K bytes - Viewed (1) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/util/KotlinSourceParser.kt
import org.jetbrains.kotlin.cli.common.CLIConfigurationKeys import org.jetbrains.kotlin.cli.common.config.addKotlinSourceRoots import org.jetbrains.kotlin.cli.common.messages.MessageCollector import org.jetbrains.kotlin.cli.common.messages.MessageRenderer import org.jetbrains.kotlin.cli.common.messages.PrintingMessageCollector import org.jetbrains.kotlin.cli.jvm.compiler.EnvironmentConfigFiles import org.jetbrains.kotlin.cli.jvm.compiler.KotlinCoreEnvironment
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Sat Sep 30 16:17:28 GMT 2023 - 4K bytes - Viewed (0) -
mockwebserver/README.md
chat.loadMore(); assertEquals("hello, world!", chat.messages()); chat.loadMore(); chat.loadMore(); assertEquals("" + "hello, world!\n" + "sup, bra?\n" + "yo dog", chat.messages()); // Optional: confirm that your app made the HTTP requests you were expecting. RecordedRequest request1 = server.takeRequest(); assertEquals("/v1/chat/messages/", request1.getPath());
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Dec 17 15:34:10 GMT 2023 - 5K bytes - Viewed (1) -
common-protos/k8s.io/api/events/v1beta1/generated.proto
// Events have a limited retention time and triggers and messages may evolve // with time. Event consumers should not rely on the timing of an event // with a given Reason reflecting a consistent underlying trigger, or the // continued existence of events with that Reason. Events should be // treated as informative, best-effort, supplemental data. message Event { // Standard object's metadata.
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 5.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/TestLogHandler.kt
import org.junit.jupiter.api.extension.ExtensionContext import org.junit.rules.TestRule import org.junit.runner.Description import org.junit.runners.model.Statement /** * A log handler that records which log messages were published so that a calling test can make * assertions about them. */ class TestLogHandler( private val logger: Logger, ) : TestRule, BeforeEachCallback, AfterEachCallback {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_cluster_audit_failed_messages` | `counter` | Total number of messages that failed to send since start | `target_id` | | `minio_cluster_audit_target_queue_length` | `gauge` | Number of unsent messages in queue for target | `target_id` | | `minio_cluster_audit_total_messages` | `counter` | Total number of messages sent since start | `target_id` |
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Apr 17 09:18:02 GMT 2024 - 20.7K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
* New: `OkHttpClient.Builder.minWebSocketMessageToCompress()` configures a threshold for compressing outbound web socket messages. Configure this with 0L to always compress outbound messages and `Long.MAX_VALUE` to never compress outbound messages. The default is 1024L which compresses messages of size 1 KiB and larger. (Inbound messages are compressed or not based on the web socket server's configuration.)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
internal/grid/README.md
# MinIO Grid The MinIO Grid is a package that provides two-way communication between servers. It uses a single two-way connection to send and receive messages between servers. It includes built in muxing of concurrent requests as well as congestion handling for streams. Requests can be "Single Payload" or "Streamed". Use the MinIO Grid for: * Small, frequent requests with low latency requirements.
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0)