io

package

v1.24.4 Latest Latest Go to latest Published: Aug 19, 2016 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/ayktx/v2ray-core

Documentation ¶

Index ¶

func Pipe(reader Reader, writer Writer) error
type AdaptiveReader
- func NewAdaptiveReader(reader io.Reader) *AdaptiveReader
- func (this *AdaptiveReader) Read() (*alloc.Buffer, error)
- func (this *AdaptiveReader) Release()
type AdaptiveWriter
- func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter
- func (this *AdaptiveWriter) Release()
- func (this *AdaptiveWriter) Write(buffer *alloc.Buffer) error
type BufferedReader
- 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
- 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
- func NewChainWriter(writer Writer) *ChainWriter
- func (this *ChainWriter) Release()
- func (this *ChainWriter) Write(payload []byte) (int, error)
type ChanReader
- func NewChanReader(stream Reader) *ChanReader
- func (this *ChanReader) Fill()
- func (this *ChanReader) Read(b []byte) (int, error)
- func (this *ChanReader) Release()
type Reader
type Writer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Pipe ¶

func Pipe(reader Reader, writer Writer) error

Types ¶

type AdaptiveReader ¶

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

AdaptiveReader is a Reader that adjusts its reading speed automatically.

func NewAdaptiveReader ¶

func NewAdaptiveReader(reader io.Reader) *AdaptiveReader

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

func (*AdaptiveReader) Read ¶

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

Read implements Reader.Read().

func (*AdaptiveReader) Release ¶

func (this *AdaptiveReader) Release()

type AdaptiveWriter ¶

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

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

func NewAdaptiveWriter ¶

func NewAdaptiveWriter(writer io.Writer) *AdaptiveWriter

NewAdaptiveWriter creates a new AdaptiveWriter.

func (*AdaptiveWriter) Release ¶

func (this *AdaptiveWriter) Release()

func (*AdaptiveWriter) Write ¶

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

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

type BufferedReader ¶

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

func NewBufferedReader ¶

func NewBufferedReader(rawReader io.Reader) *BufferedReader

func (*BufferedReader) Cached ¶

func (this *BufferedReader) Cached() bool

func (*BufferedReader) Read ¶

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

func (*BufferedReader) Release ¶

func (this *BufferedReader) Release()

func (*BufferedReader) SetCached ¶

func (this *BufferedReader) SetCached(cached bool)

type BufferedWriter ¶

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

func NewBufferedWriter ¶

func NewBufferedWriter(rawWriter io.Writer) *BufferedWriter

func (*BufferedWriter) Cached ¶

func (this *BufferedWriter) Cached() bool

func (*BufferedWriter) Flush ¶

func (this *BufferedWriter) Flush() error

func (*BufferedWriter) FlushWithoutLock ¶

func (this *BufferedWriter) FlushWithoutLock() error

func (*BufferedWriter) ReadFrom ¶

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

func (*BufferedWriter) Release ¶

func (this *BufferedWriter) Release()

func (*BufferedWriter) SetCached ¶

func (this *BufferedWriter) SetCached(cached bool)

func (*BufferedWriter) Write ¶

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

type ChainWriter ¶

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

func NewChainWriter ¶

func NewChainWriter(writer Writer) *ChainWriter

func (*ChainWriter) Release ¶

func (this *ChainWriter) Release()

func (*ChainWriter) Write ¶

func (this *ChainWriter) Write(payload []byte) (int, error)

type ChanReader ¶

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

func NewChanReader ¶

func NewChanReader(stream Reader) *ChanReader

func (*ChanReader) Fill ¶

func (this *ChanReader) Fill()

@Private

func (*ChanReader) Read ¶

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

func (*ChanReader) Release ¶

func (this *ChanReader) Release()

type Reader ¶

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 ¶

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL