- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 5,819 for message3 (0.21 sec)
-
maven-core/src/test/java/org/apache/maven/project/ProjectBuildingResultWithProblemMessageMatcher.java
description.appendText("was a ProjectBuildingResult with messages "); String messages = r.getProblems().stream() .map(ModelProblem::getMessage) .map(m -> "\"" + m + "\"" + System.lineSeparator()) .collect(joining(", ")); description.appendText(messages); } }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Dec 26 15:12:32 UTC 2022 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream.go
// client and ignore messages sent to the server. The received messages are // the exact bytes written to the stream. Zero byte messages are possible. const binaryWebSocketProtocol = "binary.k8s.io" // The WebSocket subprotocol "base64.binary.k8s.io" will only send messages to the // client and ignore messages sent to the server. The received messages are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/serializer/LogEventSerializerTest.groovy
result.logLevel == LogLevel.LIFECYCLE result.message == MESSAGE result.throwable.getClass() == event.throwable.getClass() result.throwable.message == event.throwable.message result.throwable.stackTrace == event.throwable.stackTrace result.buildOperationId == new OperationIdentifier(42L) } def "can serialize LogEvent messages"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/log/uds_test.go
json.Unmarshal([]byte(srv.messages[0]), &got[0]) json.Unmarshal([]byte(srv.messages[1]), &got[1]) if !reflect.DeepEqual(got, want) { t.Errorf("received log messages, got %v want %v", got, want) } } { t.Log("test sending log with specified time") // Clean up all the mssages, and log again. Check that buffer is cleaned up properly. srv.messages = make([]string, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 29 01:05:12 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DefaultDaemonConnectionTest.groovy
then: result*.message == ["incoming1", "incoming2"] } static class TestConnection implements RemoteConnection<Message> { private final def lock = new Object() private final def endInput = new Received("end") private final def receiveQueue = new LinkedList<Message>() @Override void dispatch(Message message) throws MessageIOException {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/extensibility/plugin-development/src/integTest/groovy/org/gradle/plugin/devel/tasks/RuntimePluginValidationTrait.groovy
def expectedDeprecations = messages .findAll { problem -> problem.severity == WARNING } def expectedFailures = messages .findAll { problem -> problem.severity == ERROR } expectedDeprecations.forEach { warning -> expectThatExecutionOptimizationDisabledWarningIsDisplayed(executer, warning.message, warning.id, warning.section) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 14:30:05 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} try { if (pong != null) { writer!!.writePong(pong) } else if (messageOrClose is Message) { val message = messageOrClose as Message writer!!.writeMessageFrame(message.formatOpcode, message.data) synchronized(this) { queueSize -= message.data.size.toLong() } } else if (messageOrClose is Close) { val close = messageOrClose as Close
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (1) -
tensorflow/compiler/mlir/quantization/stablehlo/cc/io.h
absl::StatusOr<std::vector<std::string>> ListDirectory( absl::string_view directory); template <class MessageT> absl::StatusOr<MessageT> ReadBinaryProto(const std::string& binary_file_path) { MessageT message; TF_RETURN_IF_ERROR( tsl::ReadBinaryProto(tsl::Env::Default(), binary_file_path, &message)); return message; } } // namespace stablehlo::quantization::io
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Apr 24 03:28:15 UTC 2024 - 3.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueue.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3.9K bytes - Viewed (0)