part

package

v0.28.20240402154002 Latest Latest Go to latest Published: Apr 2, 2024 License: MIT Imports: 7 Imported by: 5

Details

This section is empty.

View Source

var (
	ErrWrite = errors.New("ErrWrite")
	ErrRead  = errors.New("ErrRead")
)

func Copy(r io.Reader, w io.Writer, c CopyConfig) (e error)

close by yourself

watch out uint64(c.MaxLoop*c.BytePerLoop) overflow

func RW2Chan(r io.ReadCloser, w io.WriteCloser) (rc, wc chan []byte)

no close rc any time you can close wc, r, w.

func WithCtxCopy(ctx context.Context, callTree string, copybuf []byte, to time.Duration, w io.Writer, r io.Reader, panicf ...func(s string)) error

close reader by yourself

to avoid writer block after ctx done, you should close writer after ctx done

call Close() after writer fin

func WithCtxTO(ctx context.Context, callTree string, to time.Duration, w io.Writer, r io.Reader, panicf ...func(s string)) io.ReadWriteCloser

close reader by yourself

to avoid writer block after ctx done, you should close writer after ctx done

call Close() after writer fin

type CopyConfig struct {
	BytePerLoop, MaxLoop, MaxByte, BytePerSec uint64
}

type IOpipe struct {
	R *io.PipeReader
	W *io.PipeWriter
	// contains filtered or unexported fields
}

func NewPipe() *IOpipe

func (t *IOpipe) Close() (err error)

func (t *IOpipe) CloseWithError(e error) (err error)

func (t *IOpipe) Read(p []byte) (n int, err error)

func (t *IOpipe) Write(p []byte) (n int, err error)

type RWC struct {
	R func(p []byte) (n int, err error)
	W func(p []byte) (n int, err error)
	C func() error
}

func (t RWC) Close() error

func (t RWC) Read(p []byte) (n int, err error)

func (t RWC) Write(p []byte) (n int, err error)