Versions in this module Expand all Collapse all v0 v0.1.0 Oct 26, 2024 Changes in this version + const BufferSize + var ErrorStreamAbandoned = errors.New("stream abandoned") + type AsyncReader struct + func New(ctx context.Context, rd io.ReadCloser, buffers int) (*AsyncReader, error) + func (a *AsyncReader) Abandon() + func (a *AsyncReader) Close() (err error) + func (a *AsyncReader) Read(p []byte) (n int, err error) + func (a *AsyncReader) SkipBytes(skip int) (ok bool) + func (a *AsyncReader) StopBuffering() + func (a *AsyncReader) WriteTo(w io.Writer) (n int64, err error)
Go to main page