- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for onStatefulMessage (0.3 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/QueueInitializer.java
import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; public class QueueInitializer { private EndOfStream endOfStream; void onStatefulMessage(InterHubMessage message) { if (message instanceof EndOfStream) { endOfStream = (EndOfStream) message; } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/QueueInitializerTest.groovy
then: 0 * queue._ } def "discards message on end of stream received"() { given: def closed = new EndOfStream() initializer.onStatefulMessage(closed) when: initializer.onQueueAdded(queue) then: 1 * queue.dispatch(closed) 0 * queue._ }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueue.java
} return queue; } public void queue(InterHubMessage message) { if (message.getDelivery() == InterHubMessage.Delivery.Stateful) { initializer.onStatefulMessage(message); } if (message instanceof Routable) { Routable routableMessage = (Routable) message; getChannel(routableMessage.getChannel()).dispatch(message);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueue.java
if (endpoints.isEmpty()) { return; } if (message.getDelivery() == InterHubMessage.Delivery.Stateful) { initializer.onStatefulMessage(message); } for (EndPointQueue endpoint : endpoints) { endpoint.dispatch(message); } queue.removeFirst();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3.9K bytes - Viewed (0)