part

package

v0.28.20241212155801 Latest Latest Go to latest Published: Dec 12, 2024 License: MIT Imports: 7 Imported by: 5

Details

This section is empty.

View Source

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

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 ReadAll(r io.Reader, b []byte) ([]byte, error)

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

func WriterWithConfig(w io.Writer, c CopyConfig) (wc io.Writer)

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

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)