- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for endOfStream (0.42 sec)
-
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/SkipFirstTextStream.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 1.2K bytes - Viewed (0) -
platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/SkipFirstTextStreamTest.groovy
when: skipper.text("a") skipper.endOfStream(null) then: 1 * delegate.endOfStream(null) 0 * delegate._ } def "does not skip EOS if before first"() { given: def delegate = Mock(TextStream) def skipper = new SkipFirstTextStream(delegate) when: skipper.endOfStream(null) then: 1 * delegate.endOfStream(null)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/io/src/test/groovy/org/gradle/internal/io/LinePerThreadBufferingOutputStreamTest.groovy
then: 1 * action.text("text") 1 * action.endOfStream(null) 0 * action._ } def closeDoesNothingWhenNothingWritten() { TextStream action = Mock() def outstr = new LinePerThreadBufferingOutputStream(action) when: outstr.close() then: 1 * action.endOfStream(null) 0 * action._ }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:13 UTC 2024 - 3K 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) -
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)