- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for discardQueued (0.27 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/OutgoingQueue.java
super(lock); this.incomingQueue = incomingQueue; } void endOutput() { dispatch(new EndOfStream()); } void discardQueued() { List<InterHubMessage> rejected = new ArrayList<InterHubMessage>(); drain(rejected); for (InterHubMessage message : rejected) { if (message instanceof ChannelMessage) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
*/ public void noFurtherConnections() { stopping = true; maybeStop(); } private void maybeStop() { if (connections.isEmpty()) { outgoingQueue.discardQueued(); incomingQueue.queue(new EndOfStream()); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0)