- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for unbuffered (0.18 sec)
-
doc/godebug.md
enabled by default on listerners. Using multipathtcp="0" reverts to the pre-Go 1.24 behavior. ### Go 1.23 Go 1.23 changed the channels created by package time to be unbuffered (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop) and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Oct 28 14:46:33 UTC 2024 - 17.2K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteSink.java
* * @throws IOException if an I/O error occurs while opening the stream */ public abstract OutputStream openStream() throws IOException; /** * Opens a new buffered {@link OutputStream} for writing to this sink. The returned stream is not * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 28 16:55:09 UTC 2024 - 5K bytes - Viewed (0) -
src/bufio/bufio_test.go
t.Error("expected flush error, got nil") } if _, err := wr.ReadFrom(strings.NewReader("test2")); err == nil { t.Fatal("expected error, got nil") } if buffered := wr.Buffered(); buffered != wantBuffered { t.Fatalf("Buffered = %v; want %v", buffered, wantBuffered) } } func BenchmarkReaderCopyOptimal(b *testing.B) { // Optimal case is where the underlying reader implements io.WriterTo
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Nov 01 21:52:12 UTC 2024 - 51.6K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSink.java
* * @throws IOException if an I/O error occurs while opening the writer */ public abstract Writer openStream() throws IOException; /** * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 6.8K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} return n, err } // diskHealthReader provides a wrapper that will update disk health on // ctx, on every successful read. // This should only be used directly at the os/syscall level, // otherwise buffered operations may return false health checks. func diskHealthReader(ctx context.Context, r io.Reader) io.Reader { // Check if context has a disk health check. tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
es.stats.missedExpiryTasks.Add(1) } } // globalExpiryState is the per-node instance which manages all ILM expiry tasks. var globalExpiryState *expiryState // newExpiryState creates an expiryState with buffered channels allocated for // each ILM expiry task type. func newExpiryState(ctx context.Context, objAPI ObjectLayer, n int) *expiryState { es := &expiryState{ ctx: ctx, objAPI: objAPI, }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0)