readers

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2022 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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, err 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 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) *TeeReaderCloser

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