- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for EndOfStream (0.15 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/ConnectionSetTest.groovy
import org.gradle.internal.remote.internal.hub.protocol.ChannelIdentifier import org.gradle.internal.remote.internal.hub.protocol.ChannelMessage import org.gradle.internal.remote.internal.hub.protocol.EndOfStream import org.gradle.internal.remote.internal.hub.protocol.RejectedMessage import org.gradle.internal.remote.internal.hub.queue.AbstractQueueTest class ConnectionSetTest extends AbstractQueueTest {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueueTest.groovy
import org.gradle.internal.remote.internal.hub.protocol.ChannelIdentifier import org.gradle.internal.remote.internal.hub.protocol.ChannelMessage import org.gradle.internal.remote.internal.hub.protocol.EndOfStream class MultiChannelQueueTest extends AbstractQueueTest { final MultiChannelQueue queue = new MultiChannelQueue(lock) def "adds and caches channel queue on first lookup"() {
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/messaging/src/main/java/org/gradle/internal/remote/internal/hub/IncomingQueue.java
import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.queue.MultiChannelQueue; import java.util.concurrent.locks.Lock; class IncomingQueue extends MultiChannelQueue { IncomingQueue(Lock lock) { super(lock); } public void requestStop() { queue(new EndOfStream()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueueTest.groovy
* limitations under the License. */ package org.gradle.internal.remote.internal.hub.queue import org.gradle.internal.remote.internal.hub.protocol.EndOfStream class MultiEndPointQueueTest extends AbstractQueueTest { final MultiEndPointQueue queue = new MultiEndPointQueue(lock) def "forwards queued unicast messages to first waiting endpoint"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/QueueInitializerTest.groovy
* limitations under the License. */ package org.gradle.internal.remote.internal.hub.queue import org.gradle.internal.dispatch.Dispatch import org.gradle.internal.remote.internal.hub.protocol.EndOfStream import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage class QueueInitializerTest extends AbstractQueueTest { final QueueInitializer initializer = new QueueInitializer()
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/MultiEndPointQueue.java
* limitations under the License. */ package org.gradle.internal.remote.internal.hub.queue; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.remote.internal.hub.protocol.EndOfStream; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.Collection; import java.util.Deque; import java.util.HashSet;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3.9K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/process/internal/streams/ExecOutputHandleRunnerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 08 14:24:34 UTC 2021 - 2.2K bytes - Viewed (0) -
platforms/native/testing-native/src/main/java/org/gradle/nativeplatform/test/xctest/internal/execution/XCTestExecuter.java
result.rethrowFailure().assertNormalExitValue(); } } catch (ExecException e) { stdOut.endOfStream(e); stdErr.endOfStream(null); } finally { execHandle = null; } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 8.1K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/WriterTextStream.java
try { delegate.write(text); } catch (IOException e) { throw UncheckedException.throwAsUncheckedException(e); } } @Override public void endOfStream(@Nullable Throwable failure) { try { delegate.close(); } catch (IOException e) { if (failure == null) { throw UncheckedException.throwAsUncheckedException(e);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/TextStream.java
void text(String text); /** * Called when the end of the stream is reached for some reason. * * @param failure The failure, if any, which caused the end of the stream. */ void endOfStream(@Nullable Throwable failure);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 1K bytes - Viewed (0)