- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 270 for wrapping (0.21 sec)
-
cmd/api-router.go
tracedHandler = httpTraceHdrs(f) } else { tracedHandler = httpTraceAll(f) } // Skip wrapping with the gzip middleware if specified. var gzippedHandler http.HandlerFunc = tracedHandler if !handlerFlags.has(noGZS3HFlag) { gzippedHandler = gzipHandler(gzippedHandler) } // Skip wrapping with throttling middleware if specified. var throttledHandler http.HandlerFunc = gzippedHandler
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharStreamsTest.java
// nothing really to assert? assertSame(CharStreams.nullWriter(), CharStreams.nullWriter()); } /** * Returns a reader wrapping the given reader that only reads half of the maximum number of * characters that it could read in read(char[], int, int). */ private static Reader newNonBufferFillingReader(Reader reader) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharStreamsTest.java
// nothing really to assert? assertSame(CharStreams.nullWriter(), CharStreams.nullWriter()); } /** * Returns a reader wrapping the given reader that only reads half of the maximum number of * characters that it could read in read(char[], int, int). */ private static Reader newNonBufferFillingReader(Reader reader) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.2K bytes - Viewed (0) -
internal/ioutil/ioutil.go
return &LimitWriter{w, skipBytes, limit} } type nopCloser struct { io.Writer } func (nopCloser) Close() error { return nil } // NopCloser returns a WriteCloser with a no-op Close method wrapping // the provided Writer w. func NopCloser(w io.Writer) io.WriteCloser { return nopCloser{w} } // SkipReader skips a given number of bytes and then returns all // remaining data. type SkipReader struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* invokeAll}, and {@code invokeAny} methods, so any special handling of tasks must be implemented * in the delegate's {@code execute} method or by wrapping the returned {@code * ListeningExecutorService}. * * <p>If the delegate executor was already an instance of {@code ListeningExecutorService}, it is
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
src/bufio/scan_test.go
} } if s.Err() != nil { t.Fatal("after scan:", s.Err()) } } // negativeEOFReader returns an invalid -1 at the end, as though it // were wrapping the read system call. type negativeEOFReader int func (r *negativeEOFReader) Read(p []byte) (int, error) { if *r > 0 { c := int(*r) if c > len(p) { c = len(p) } for i := 0; i < c; i++ {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
misc/go_android_exec/main.go
// However, if the os.Stderr (or os.Stdout) file descriptors are // passed on, the hanging adb subprocess will hold them open and // go test will hang forever. // // Avoid that by wrapping stderr, breaking the short circuit and // forcing cmd.Run to use another pipe and goroutine to pass // along stderr from adb. cmd.Stderr = struct{ io.Writer }{os.Stderr} err := cmd.Run()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
threadFail("should throw " + exceptionName); } /** * Records the given exception using {@link #threadRecordFailure}, then rethrows the exception, * wrapping it in an AssertionFailedError if necessary. */ public void threadUnexpectedException(Throwable t) { threadRecordFailure(t); t.printStackTrace();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
threadFail("should throw " + exceptionName); } /** * Records the given exception using {@link #threadRecordFailure}, then rethrows the exception, * wrapping it in an AssertionFailedError if necessary. */ public void threadUnexpectedException(Throwable t) { threadRecordFailure(t); t.printStackTrace();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* ClosingFuture} call {@link #from(ListenableFuture)}. * <li>In case this step doesn't create new closeables, you can adapt an API that returns a * {@link ListenableFuture} to return a {@code ClosingFuture} by wrapping it with a call to * {@link #withoutCloser(AsyncFunction)} * </ul> * * <p>Example usage: * * <pre>{@code * // Result.getRowsClosingFuture() returns a ClosingFuture.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0)