mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2024-11-15 07:09:47 +01:00
…
|
||
---|---|---|
.. | ||
bufpipe.go | ||
doc.go | ||
go.mod | ||
go.sum | ||
README.md |
bufpipe: Buffered Pipe
The buffered version of io.Pipe. It's safe for concurrent use.
How does it differ from io.Pipe?
Writes never block because the pipe has variable-sized buffer.
r, w := bufpipe.New(nil)
io.WriteString(w, "abc") // No blocking.
io.WriteString(w, "def") // No blocking, too.
w.Close()
io.Copy(os.Stdout, r)
// Output: abcdef
How does it differ from bytes.Buffer?
Reads block if the internal buffer is empty until the writer is closed.
r, w := bufpipe.New(nil)
done := make(chan struct{})
go func() {
io.Copy(os.Stdout, r) // The reads block until the writer is closed.
done <- struct{}{}
}()
io.WriteString(w, "abc")
io.WriteString(w, "def")
w.Close()
<-done
// Output: abcdef