readers

package
v1.3.8 Latest Latest
Warning

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

Go to latest
Published: May 1, 2024 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPrintReader added in v0.5.5

func NewPrintReader(rawReader io.Reader, tag string) io.Reader

Types

type BaseReader

type BaseReader struct {
}

type ByteRangesReaderCloser

type ByteRangesReaderCloser struct {
	BaseReader
	// contains filtered or unexported fields
}

func NewByteRangesReaderCloser

func NewByteRangesReaderCloser(reader io.ReadCloser, boundary string) *ByteRangesReaderCloser

func (*ByteRangesReaderCloser) Close

func (this *ByteRangesReaderCloser) Close() error

func (*ByteRangesReaderCloser) OnPartRead

func (this *ByteRangesReaderCloser) OnPartRead(handler OnPartReadHandler)

func (*ByteRangesReaderCloser) Read

func (this *ByteRangesReaderCloser) Read(p []byte) (n int, err error)

type BytesCounterReader

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

func NewBytesCounterReader

func NewBytesCounterReader(rawReader io.Reader) *BytesCounterReader

func (*BytesCounterReader) Read

func (this *BytesCounterReader) Read(p []byte) (n int, err error)

func (*BytesCounterReader) TotalBytes

func (this *BytesCounterReader) TotalBytes() int64

type FilterFunc

type FilterFunc = func(p []byte, readErr error) error

type FilterReaderCloser

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

func NewFilterReaderCloser

func NewFilterReaderCloser(rawReader io.Reader) *FilterReaderCloser

func (*FilterReaderCloser) Add

func (this *FilterReaderCloser) Add(filter FilterFunc)

func (*FilterReaderCloser) Close

func (this *FilterReaderCloser) Close() error

func (*FilterReaderCloser) Read

func (this *FilterReaderCloser) Read(p []byte) (n int, err error)

type OnPartReadHandler

type OnPartReadHandler func(start int64, end int64, total int64, data []byte, header textproto.MIMEHeader)

type PrintReader added in v0.5.5

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

func (*PrintReader) Read added in v0.5.5

func (this *PrintReader) Read(p []byte) (n int, err error)

type TeeReader

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

func NewTeeReader

func NewTeeReader(reader io.Reader, writer io.Writer) *TeeReader

func (*TeeReader) OnEOF

func (this *TeeReader) OnEOF(onEOF func())

func (*TeeReader) OnFail

func (this *TeeReader) OnFail(onFail func(err error))

func (*TeeReader) Read

func (this *TeeReader) Read(p []byte) (n int, err error)

type TeeReaderCloser

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

func NewTeeReaderCloser

func NewTeeReaderCloser(reader io.Reader, writer io.Writer, mustWrite bool) *TeeReaderCloser

NewTeeReaderCloser mustWrite - ensure writing MUST be successfully

func (*TeeReaderCloser) Close

func (this *TeeReaderCloser) Close() error

func (*TeeReaderCloser) OnEOF

func (this *TeeReaderCloser) OnEOF(onEOF func())

func (*TeeReaderCloser) OnFail

func (this *TeeReaderCloser) OnFail(onFail func(err error))

func (*TeeReaderCloser) Read

func (this *TeeReaderCloser) Read(p []byte) (n int, err error)

Jump to

Keyboard shortcuts

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