- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for EndOfStream (0.16 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHub.java
addToIncoming(new StreamFailureMessage(e)); continue; } if (message == null || message instanceof EndOfStream) { return; } addToIncoming(message); } } finally { lock.lock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 16.2K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/redirector/DefaultStandardOutputRedirector.java
private OutputListener destination; @Override public void text(String message) { destination.onOutput(message); } @Override public void endOfStream(@Nullable Throwable failure) { } public void setDestination(OutputListener destination) { this.destination = destination; } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LineBufferingOutputStream.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LinePerThreadBufferingOutputStream.java
public void close() { PrintStream currentStream = maybeGetStream(); if (currentStream != null) { stream.remove(); currentStream.close(); } else { handler.endOfStream(null); } } @Override public void flush() { PrintStream stream = maybeGetStream(); if (stream != null) { stream.flush(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 6K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubTest.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.InterHubMessage import org.gradle.test.fixtures.concurrent.ConcurrentSpec import spock.lang.Timeout import java.util.concurrent.BlockingQueue
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/logging/src/main/java/org/gradle/internal/logging/source/PrintStreamLoggingSystem.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 5.9K bytes - Viewed (0) -
platforms/native/testing-native/src/main/java/org/gradle/nativeplatform/test/xctest/internal/execution/XCTestScraper.java
} } } } } @Override public void endOfStream(@Nullable Throwable failure) { if (failure != null) { synchronized (testDescriptors) { Object testId; if (!testDescriptors.isEmpty()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 9.7K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 967.9K bytes - Viewed (0)