io

package
v1.13.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 22, 2016 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Pipe added in v1.11.1 

func Pipe(reader Reader, writer Writer) error

func ReadFrom added in v1.9.1 

func ReadFrom(reader io.Reader, buffer *alloc.Buffer) (*alloc.Buffer, error)

ReadFrom reads from a reader and put all content to a buffer. If buffer is nil, ReadFrom creates a new normal buffer.

Types

type AdaptiveReader added in v1.9.1 

type AdaptiveReader struct {
	// contains filtered or unexported fields
}

AdaptiveReader is a Reader that adjusts its reading speed automatically.

func NewAdaptiveReader added in v1.9.1 

func NewAdaptiveReader(reader io.Reader) *AdaptiveReader

NewAdaptiveReader creates a new AdaptiveReader. The AdaptiveReader instance doesn't take the ownership of reader.

func (*AdaptiveReader) Read added in v1.9.1 

func (this *AdaptiveReader) Read() (*alloc.Buffer, error)

Read implements Reader.Read().

func (*AdaptiveReader) Release added in v1.11.1 

func (this *AdaptiveReader) Release()

type AdaptiveWriter added in v1.9.1 

type AdaptiveWriter struct {
	// contains filtered or unexported fields
}

AdaptiveWriter is a Writer that writes alloc.Buffer into underlying writer.

func NewAdaptiveWriter added in v1.9.1 

func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter

NewAdaptiveWriter creates a new AdaptiveWriter.

func (*AdaptiveWriter) Release added in v1.11.1 

func (this *AdaptiveWriter) Release()

func (*AdaptiveWriter) Write added in v1.9.1 

func (this *AdaptiveWriter) Write(buffer *alloc.Buffer) error

Write implements Writer.Write(). Write() takes ownership of the given buffer.

type BufferedReader added in v1.9.1 

type BufferedReader struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBufferedReader added in v1.9.1 

func NewBufferedReader(rawReader io.Reader) *BufferedReader

func (*BufferedReader) Cached added in v1.9.1 

func (this *BufferedReader) Cached() bool

func (*BufferedReader) Read added in v1.9.1 

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

func (*BufferedReader) Release added in v1.9.1 

func (this *BufferedReader) Release()

func (*BufferedReader) SetCached added in v1.9.1 

func (this *BufferedReader) SetCached(cached bool)

type BufferedWriter added in v1.9.1 

type BufferedWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBufferedWriter added in v1.9.1 

func NewBufferedWriter(rawWriter io.Writer) *BufferedWriter

func (*BufferedWriter) Cached added in v1.9.1 

func (this *BufferedWriter) Cached() bool

func (*BufferedWriter) Flush added in v1.9.1 

func (this *BufferedWriter) Flush() error

func (*BufferedWriter) Release added in v1.9.1 

func (this *BufferedWriter) Release()

func (*BufferedWriter) SetCached added in v1.9.1 

func (this *BufferedWriter) SetCached(cached bool)

func (*BufferedWriter) Write added in v1.9.1 

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

type Reader added in v1.9.1 

type Reader interface {
	common.Releasable
	// Read reads content from underlying reader, and put it into an alloc.Buffer.
	Read() (*alloc.Buffer, error)
}

Reader extends io.Reader with alloc.Buffer.

type Writer added in v1.9.1 

type Writer interface {
	common.Releasable
	// Write writes an alloc.Buffer into underlying writer.
	Write(*alloc.Buffer) error
}

Writer extends io.Writer with alloc.Buffer.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.