aio

package

v0.11.18 Latest Latest Go to latest Published: May 12, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewAsyncReader(r io.Reader, opts ...Option) *AsyncReader

func (ar *AsyncReader) Close() error

func (ar *AsyncReader) Read(p []byte) (int, error)

func (ar *AsyncReader) WriteTo(w io.Writer) (n int64, err error)

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

func NewAsyncWriter(w io.Writer, opts ...Option) *AsyncWriter

func (aw *AsyncWriter) Close() error

func (aw *AsyncWriter) Flush()

func (aw *AsyncWriter) ReadFrom(r io.Reader) (n int64, err error)

func (aw *AsyncWriter) Write(p []byte) (n int, err error)

type Option func(*option)

func BufSize(bufSize int) Option

func Deadline(deadline time.Duration) Option

Deadline Only for AsyncWriter Flush.

func QueueSize(queueSize int) Option