You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
zeripath
23358bc55d
|
3 years ago | |
---|---|---|
.. | ||
.travis.yml | 3 years ago | |
LICENSE.txt | 3 years ago | |
README.md | 3 years ago | |
go.mod | 3 years ago | |
go.sum | 3 years ago | |
nio.go | 3 years ago | |
sync.go | 3 years ago |
README.md
nio
Usage
The Buffer interface:
type Buffer interface {
Len() int64
Cap() int64
io.ReadWriter
}
nio's Copy method concurrently copies from an io.Reader to a supplied nio.Buffer, then from the nio.Buffer to an io.Writer. This way, blocking writes don't slow the io.Reader.
import (
"github.com/djherbis/buffer"
"github.com/djherbis/nio"
)
buf := buffer.New(32*1024) // 32KB In memory Buffer
nio.Copy(w, r, buf) // Reads and Writes concurrently, buffering using buf.
nio's Pipe method is a buffered version of io.Pipe The writer return once its data has been written to the Buffer. The reader returns with data off the Buffer.
import (
"gopkg.in/djherbis/buffer.v1"
"gopkg.in/djherbis/nio.v2"
)
buf := buffer.New(32*1024) // 32KB In memory Buffer
r, w := nio.Pipe(buf)
Installation
go get gopkg.in/djherbis/nio.v2
For some pre-built buffers grab:
go get gopkg.in/djherbis/buffer.v1
Mentions
GopherCon 2017: Peter Bourgon - Evolutionary Optimization with Go