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
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gopherty/v2ray-core

Links

Open Source Insights

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 ¶ added in v1.11.1

func Pipe(reader Reader, writer Writer) error

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) FlushWithoutLock ¶ added in v1.17.1

func (this *BufferedWriter) FlushWithoutLock() error

func (*BufferedWriter) ReadFrom ¶ added in v1.17.1

func (this *BufferedWriter) ReadFrom(reader io.Reader) (int64, 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 ChainWriter ¶ added in v1.17.1

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

func NewChainWriter ¶ added in v1.17.1

func NewChainWriter(writer Writer) *ChainWriter

func (*ChainWriter) Release ¶ added in v1.17.1

func (this *ChainWriter) Release()

func (*ChainWriter) Write ¶ added in v1.17.1

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

type ChanReader ¶ added in v1.17.1

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

func NewChanReader ¶ added in v1.17.1

func NewChanReader(stream Reader) *ChanReader

func (*ChanReader) Fill ¶ added in v1.17.1

func (this *ChanReader) Fill()

@Private

func (*ChanReader) Read ¶ added in v1.17.1

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

func (*ChanReader) Release ¶ added in v1.17.1

func (this *ChanReader) Release()

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

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