Versions in this module Expand all Collapse all v1 v1.24.4 Aug 19, 2016 Changes in this version + func Pipe(reader Reader, writer Writer) error + type AdaptiveReader struct + func NewAdaptiveReader(reader io.Reader) *AdaptiveReader + func (this *AdaptiveReader) Read() (*alloc.Buffer, error) + func (this *AdaptiveReader) Release() + type AdaptiveWriter struct + func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter + func (this *AdaptiveWriter) Release() + func (this *AdaptiveWriter) Write(buffer *alloc.Buffer) error + type BufferedReader struct + func NewBufferedReader(rawReader io.Reader) *BufferedReader + func (this *BufferedReader) Cached() bool + func (this *BufferedReader) Read(b []byte) (int, error) + func (this *BufferedReader) Release() + func (this *BufferedReader) SetCached(cached bool) + type BufferedWriter struct + func NewBufferedWriter(rawWriter io.Writer) *BufferedWriter + func (this *BufferedWriter) Cached() bool + func (this *BufferedWriter) Flush() error + func (this *BufferedWriter) FlushWithoutLock() error + func (this *BufferedWriter) ReadFrom(reader io.Reader) (int64, error) + func (this *BufferedWriter) Release() + func (this *BufferedWriter) SetCached(cached bool) + func (this *BufferedWriter) Write(b []byte) (int, error) + type ChainWriter struct + func NewChainWriter(writer Writer) *ChainWriter + func (this *ChainWriter) Release() + func (this *ChainWriter) Write(payload []byte) (int, error) + type ChanReader struct + func NewChanReader(stream Reader) *ChanReader + func (this *ChanReader) Fill() + func (this *ChanReader) Read(b []byte) (int, error) + func (this *ChanReader) Release() + type Reader interface + Read func() (*alloc.Buffer, error) + type Writer interface + Write func(*alloc.Buffer) error
Go to main page