- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,308 for message_0 (0.18 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueueTest.groovy
queue.dispatch(message) queue.dispatch(message2) def messages1 = [] endpoint1.take(messages1) def messages2 = [] endpoint2.take(messages2) then: messages1 == [message] messages2 == [message] } def "forwards broadcast messages to all endpoints when nothing queued"() { given: def message = broadcast()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
// Empty server to client message. val message3 = "" server.send(message3) clientListener.assertTextMessage(message3) // Empty client to server message. val message4 = "" client.send(message4) serverListener.assertTextMessage(message4) // Server to client message that shares context with message1. val message5 = message1 + message1
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueueTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.2K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/test/groovy/org/gradle/launcher/daemon/protocol/DaemonMessageSerializerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/config/analysis/msg/messages.go
// limitations under the License. package msg // Create static initializers file //go:generate go run generate.main.go messages.yaml messages.gen.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 28 16:55:31 UTC 2023 - 762 bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsToolingApiPhasedBuildActionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 10.4K bytes - Viewed (0) -
src/vendor/golang.org/x/net/route/message.go
const ( SysMetrics SysType = iota SysStats ) // ParseRIB parses b as a routing information base and returns a list // of routing messages. func ParseRIB(typ RIBType, b []byte) ([]Message, error) { if !typ.parseable() { return nil, errUnsupportedMessage } var msgs []Message nmsgs, nskips := 0, 0 for len(b) > 4 { nmsgs++ l := int(nativeEndian.Uint16(b[:2])) if l == 0 { return nil, errInvalidMessage
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/documentation/docs/src/samples/templates/build-src-plugin-java-module-transform/application/src/main/java/org/gradle/sample/app/data/Message.java
package org.gradle.sample.app.data; import java.util.List; import java.util.ArrayList; public class Message { private String message; private List<String> receivers = new ArrayList<>(); public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } public List<String> getReceivers() { return receivers; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 670 bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.groovy
def "each outgoing message is dispatched in order to connection"() { def messages = new CopyOnWriteArrayList() RemoteConnection<InterHubMessage> outgoing = Mock() def connection = new MockOutgoingConnection(outgoing) given: outgoing.dispatch({ it instanceof ChannelMessage }) >> { ChannelMessage message -> messages.add(message.payload) if (messages.size() == 20) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 21.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/InterHubMessageSerializerTest.groovy
def channelId = new ChannelIdentifier("channel name") def message1 = new ChannelMessage(channelId, "payload 1") def message2 = new ChannelMessage(channelId, "payload 2") given: def message1Serialized = serialize(message1) def message2Serialized = serialize(message2) when: def serialized = serialize(message1, message2) def result = deserializeMultiple(serialized, 2)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.5K bytes - Viewed (0)