buf

Oct 28, 2018

Changes in this version

+ func IsReadError(err error) bool

+ func IsWriteError(err error) bool

Aug 31, 2018

Changes in this version

+ type ReadVReader struct — windows/amd64

+ func (r *ReadVReader) ReadMultiBuffer() (MultiBuffer, error)

Aug 5, 2018

Changes in this version

type Buffer

+ func (b *Buffer) WriteBytes(bytes ...byte) (int, error)

+ type SequentialWriter struct

+ func (w *SequentialWriter) WriteMultiBuffer(mb MultiBuffer) error

+ type SingleReader struct

+ func (r *SingleReader) ReadMultiBuffer() (MultiBuffer, error)

Jul 29, 2018

Changes in this version

+ func WriteAllBytes(writer io.Writer, payload []byte) error

+ type ReadVReader struct — darwin/amd64, js/wasm, linux/amd64

+ func NewReadVReader(reader io.Reader, rawConn syscall.RawConn) *ReadVReader

+ func (r *ReadVReader) ReadMultiBuffer() (MultiBuffer, error)

type Reader — windows/amd64

+ func NewReadVReader(reader io.Reader, rawConn syscall.RawConn) Reader

Jul 1, 2018

Changes in this version

+ var ErrNotTimeoutReader = newError("not a TimeoutReader")

+ func CopyOnceTimeout(reader Reader, writer Writer, timeout time.Duration) error

type TimeoutReader

+ ReadMultiBufferTimeout func(time.Duration) (MultiBuffer, error)

May 11, 2018

Changes in this version

type BufferedReader

+ Buffer MultiBuffer

+ Direct bool

+ Reader Reader

Apr 20, 2018

Changes in this version

type Buffer

+ func (b *Buffer) Advance(from int32)

+ func (b *Buffer) Resize(from, to int32)

Apr 18, 2018

Changes in this version

type BufferedReader

+ func (r *BufferedReader) Close() error

type BufferedWriter

+ func (w *BufferedWriter) Close() error

type MultiBuffer

+ func (mb *MultiBuffer) WriteMultiBuffer(b MultiBuffer) error

Apr 13, 2018

Changes in this version

type MultiBuffer

+ func (mb *MultiBuffer) ReadFrom(reader io.Reader) (int64, error)

+ func (mb *MultiBuffer) WriteTo(writer io.Writer) (int64, error)

Apr 13, 2018

Changes in this version

type Buffer

+ func NewSize(capacity int32) *Buffer

type BufferedReader

+ func (r *BufferedReader) BufferedBytes() int32

type MultiBuffer

+ func ReadSizeToMultiBuffer(reader io.Reader, size int32) (MultiBuffer, error)

+ func (mb MultiBuffer) String() string

Dec 1, 2017

Changes in this version

+ const Size

+ var ErrReadTimeout = newError("IO timeout")

+ func Copy(reader Reader, writer Writer, options ...CopyOption) error

+ func ReadAllToBytes(reader io.Reader) ([]byte, error)

+ type Buffer struct

+ func New() *Buffer

+ func NewLocal(size int) *Buffer

+ func (b *Buffer) Append(data []byte) int

+ func (b *Buffer) AppendBytes(bytes ...byte) int

+ func (b *Buffer) AppendSupplier(writer Supplier) error

+ func (b *Buffer) Byte(index int) byte

+ func (b *Buffer) Bytes() []byte

+ func (b *Buffer) BytesFrom(from int) []byte

+ func (b *Buffer) BytesRange(from, to int) []byte

+ func (b *Buffer) BytesTo(to int) []byte

+ func (b *Buffer) Clear()

+ func (b *Buffer) IsEmpty() bool

+ func (b *Buffer) IsFull() bool

+ func (b *Buffer) Len() int

+ func (b *Buffer) Read(data []byte) (int, error)

+ func (b *Buffer) Release()

+ func (b *Buffer) Reset(writer Supplier) error

+ func (b *Buffer) SetByte(index int, value byte)

+ func (b *Buffer) Slice(from, to int)

+ func (b *Buffer) SliceFrom(from int)

+ func (b *Buffer) String() string

+ func (b *Buffer) Write(data []byte) (int, error)

+ type BufferToBytesWriter struct

+ func NewBufferToBytesWriter(writer io.Writer) *BufferToBytesWriter

+ func (w *BufferToBytesWriter) ReadFrom(reader io.Reader) (int64, error)

+ func (w *BufferToBytesWriter) WriteMultiBuffer(mb MultiBuffer) error

+ type BufferedReader struct

+ func NewBufferedReader(reader Reader) *BufferedReader

+ func (r *BufferedReader) IsBuffered() bool

+ func (r *BufferedReader) Read(b []byte) (int, error)

+ func (r *BufferedReader) ReadAtMost(size int) (MultiBuffer, error)

+ func (r *BufferedReader) ReadByte() (byte, error)

+ func (r *BufferedReader) ReadMultiBuffer() (MultiBuffer, error)

+ func (r *BufferedReader) SetBuffered(f bool)

+ func (r *BufferedReader) WriteTo(writer io.Writer) (int64, error)

+ type BufferedWriter struct

+ func NewBufferedWriter(writer Writer) *BufferedWriter

+ func (w *BufferedWriter) Flush() error

+ func (w *BufferedWriter) ReadFrom(reader io.Reader) (int64, error)

+ func (w *BufferedWriter) SetBuffered(f bool) error

+ func (w *BufferedWriter) Write(b []byte) (int, error)

+ func (w *BufferedWriter) WriteByte(c byte) error

+ func (w *BufferedWriter) WriteMultiBuffer(b MultiBuffer) error

+ type BytesToBufferReader struct

+ func (r *BytesToBufferReader) ReadMultiBuffer() (MultiBuffer, error)

+ type CopyOption func(*copyHandler)

+ func CountSize(sc *SizeCounter) CopyOption

+ func IgnoreReaderError() CopyOption

+ func IgnoreWriterError() CopyOption

+ func UpdateActivity(timer signal.ActivityUpdater) CopyOption

+ type MultiBuffer []*Buffer

+ func NewMultiBufferCap(capacity int) MultiBuffer

+ func NewMultiBufferValue(b ...*Buffer) MultiBuffer

+ func ReadAllToMultiBuffer(reader io.Reader) (MultiBuffer, error)

+ func (mb *MultiBuffer) Append(buf *Buffer)

+ func (mb *MultiBuffer) AppendMulti(buf MultiBuffer)

+ func (mb *MultiBuffer) Read(b []byte) (int, error)

+ func (mb *MultiBuffer) Release()

+ func (mb *MultiBuffer) SliceBySize(size int) MultiBuffer

+ func (mb *MultiBuffer) SplitFirst() *Buffer

+ func (mb *MultiBuffer) Write(b []byte)

+ func (mb MultiBuffer) Copy(b []byte) int

+ func (mb MultiBuffer) IsEmpty() bool

+ func (mb MultiBuffer) Len() int

+ func (mb MultiBuffer) ToNetBuffers() net.Buffers

+ type Pool interface

+ Allocate func() *Buffer

+ Free func(*Buffer)

+ type Reader interface

+ ReadMultiBuffer func() (MultiBuffer, error)

+ func NewBytesToBufferReader(reader io.Reader) Reader

+ func NewReader(reader io.Reader) Reader

+ type SizeCounter struct

+ Size int64

+ type Supplier func([]byte) (int, error)

+ func ReadAtLeastFrom(reader io.Reader, size int) Supplier

+ func ReadFrom(reader io.Reader) Supplier

+ func ReadFullFrom(reader io.Reader, size int) Supplier

+ type SyncPool struct

+ func NewSyncPool(bufferSize uint32) *SyncPool

+ func (p *SyncPool) Allocate() *Buffer

+ func (p *SyncPool) Free(buffer *Buffer)

+ type TimeoutReader interface

+ ReadTimeout func(time.Duration) (MultiBuffer, error)

+ type Writer interface

+ WriteMultiBuffer func(MultiBuffer) error

+ var Discard Writer = noOpWriter{}

+ var DiscardBytes io.Writer = noOpWriter{}

+ func NewSequentialWriter(writer io.Writer) Writer

+ func NewWriter(writer io.Writer) Writer