readers

package
v1.3.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LimitReaderWithOverrunError

func LimitReaderWithOverrunError(r io.ReadCloser, n int64) io.ReadCloser

func MakeCloser

func MakeCloser(r io.Reader) io.ReadCloser

func NopSeekCloser

func NopSeekCloser(r io.ReadSeeker) io.ReadSeekCloser

Types

type BufferReadsReader

type BufferReadsReader struct {
	io.Reader
	// contains filtered or unexported fields
}

func NewBufferReadsReader

func NewBufferReadsReader(r io.Reader) *BufferReadsReader

func (*BufferReadsReader) GetRewoundReader

func (r *BufferReadsReader) GetRewoundReader() io.Reader

func (*BufferReadsReader) MakeRewoundReader

func (r *BufferReadsReader) MakeRewoundReader() (io.Reader, error)

func (*BufferReadsReader) Read

func (r *BufferReadsReader) Read(p []byte) (int, error)

type CancelCloser

type CancelCloser struct {
	io.ReadCloser
	// contains filtered or unexported fields
}

func (*CancelCloser) Close

func (c *CancelCloser) Close() error

type CancelSeekCloser

type CancelSeekCloser struct {
	io.ReadSeekCloser
	// contains filtered or unexported fields
}

func (*CancelSeekCloser) Close

func (c *CancelSeekCloser) Close() error

type CancellableCloser

type CancellableCloser interface {
	io.ReadCloser
}

func NewCancelCloser

func NewCancelCloser(r io.ReadCloser, cancel func()) CancellableCloser

type RewindReader

type RewindReader struct {
	io.ReadCloser
	// contains filtered or unexported fields
}

func NewRewindReader

func NewRewindReader(r io.ReadSeeker) *RewindReader

func (*RewindReader) Close

func (r *RewindReader) Close() error

func (*RewindReader) Read

func (r *RewindReader) Read(p []byte) (int, error)

type TempFileCloser

type TempFileCloser struct {
	io.ReadSeekCloser
	// contains filtered or unexported fields
}

func NewTempFileCloser

func NewTempFileCloser(fpath string, fname string, upstream io.ReadSeekCloser) *TempFileCloser

func (*TempFileCloser) Close

func (c *TempFileCloser) Close() error

func (*TempFileCloser) Read

func (c *TempFileCloser) Read(p []byte) (n int, err error)

func (*TempFileCloser) Seek

func (c *TempFileCloser) Seek(offset int64, whence int) (int64, error)

Jump to

Keyboard shortcuts

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