- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 316 for _flush (0.3 sec)
-
guava/src/com/google/common/io/Flushables.java
* method * @throws IOException if {@code swallowIOException} is false and {@link Flushable#flush} throws * an {@code IOException}. * @see Closeables#close */ public static void flush(Flushable flushable, boolean swallowIOException) throws IOException { try { flushable.flush(); } catch (IOException e) { if (swallowIOException) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Flushables.java
* method * @throws IOException if {@code swallowIOException} is false and {@link Flushable#flush} throws * an {@code IOException}. * @see Closeables#close */ public static void flush(Flushable flushable, boolean swallowIOException) throws IOException { try { flushable.flush(); } catch (IOException e) { if (swallowIOException) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 2.5K bytes - Viewed (0) -
src/encoding/csv/writer.go
} else { err = w.w.WriteByte('\n') } return err } // Flush writes any buffered data to the underlying [io.Writer]. // To check if an error occurred during Flush, call [Writer.Error]. func (w *Writer) Flush() { w.w.Flush() } // Error reports any error that has occurred during // a previous [Writer.Write] or [Writer.Flush]. func (w *Writer) Error() error { _, err := w.w.Write(nil) return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 4.8K bytes - Viewed (0) -
src/runtime/testdata/testwinlib/main.c
{ printf("cannot add vectored exception handler\n"); fflush(stdout); return 2; } void *continueHandlerHandle = AddVectoredContinueHandler(0, customContinueHandlder); if (NULL == continueHandlerHandle) { printf("cannot add vectored continue handler\n"); fflush(stdout); return 2; }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 05 08:26:52 UTC 2023 - 2.5K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/WorkInProgressRendererTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 5.1K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/ThrottlingOutputEventListenerTest.groovy
10_000 * listener.onOutput(_) } def "background flush does nothing when events already flushed"() { def event1 = event('1') def event2 = event('2') def flush = new FlushOutputEvent() given: renderer.onOutput(event1) renderer.onOutput(event2) renderer.onOutput(flush) when: executor.runFixedScheduledActionsNow()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 4.6K bytes - Viewed (0) -
src/net/http/responsecontroller.go
} type rwUnwrapper interface { Unwrap() ResponseWriter } // Flush flushes buffered data to the client. func (c *ResponseController) Flush() error { rw := c.rw for { switch t := rw.(type) { case interface{ FlushError() error }: return t.FlushError() case Flusher: t.Flush() return nil case rwUnwrapper: rw = t.Unwrap() default: return errNotSupported()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/stream/EncodedStreamTest.groovy
def "can encode and decode an empty stream"() { def outputStream = new ByteArrayOutputStream() def encoder = new EncodedStream.EncodedOutput(outputStream) when: encoder.flush() then: def inputStream = new ByteArrayInputStream(outputStream.toByteArray()) def decoder = new EncodedStream.EncodedInput(inputStream) decoder.read() < 0 }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/ExclusiveCacheAccessingWorkerTest.groovy
cacheAccessWorker.flush() then: counter == 3 cleanup: cacheAccessWorker?.stop() } def "flush rethrows action failure"() { def failure = new RuntimeException() cacheAccessWorker.enqueue { throw failure } when: start(cacheAccessWorker) cacheAccessWorker.flush() then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 4.9K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/cli/ExceptionReportingActionTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3K bytes - Viewed (0)