Documentation
¶
Index ¶
- Variables
- func ReadAllString(reader io.Reader) (out string, err error)
- func TransferDataWithSplitReadAndWrites(dest ByteBlockWriterI, nBytesToRead int, r ByteReadReaderI, ...) (singleByteReads int, blockReads int, bytesBlockReads int, n int, err error)
- type AnonymousCloseWriter
- type ByteBlockDiscardReaderI
- type ByteBlockWriterI
- type ByteReadReaderI
- type BytesBlockByteReadReader
- type DeferredTee
- func (inst *DeferredTee) Discard(n int) (int, error)
- func (inst *DeferredTee) DiscardAndFlush(n int) (nWritten int, err error)
- func (inst *DeferredTee) Flush() (int, error)
- func (inst *DeferredTee) Peek(n int) ([]byte, error)
- func (inst *DeferredTee) Read(p []byte) (n int, err error)
- func (inst *DeferredTee) ReadByte() (b byte, err error)
- type SizeMeasureWriter
- type SplicingReader
- type TeeByteReader
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrSplicingReaderAlreadySet = eh.Errorf("splicing reader is already set")
View Source
var PackageProps = packageprops.Props{ WASMWASI: packageprops.WASMCompiles, WASMJS: packageprops.WASMCompiles, WASMFreestanding: packageprops.WASMCompiles, }
PackageProps records this package's curated properties (ADR-0080). Seeded by `boxer code analysis golang wasmsurvey props generate`; curate by hand. The same group's `props verify` reconciles it.
Functions ¶
func TransferDataWithSplitReadAndWrites ¶
func TransferDataWithSplitReadAndWrites(dest ByteBlockWriterI, nBytesToRead int, r ByteReadReaderI, maxConsecutiveBytesToRead int, ra *rand.Rand) (singleByteReads int, blockReads int, bytesBlockReads int, n int, err error)
TransferDataWithSplitReadAndWrites copies nBytesToRead from r to dest by randomly using io.Reader and io.ByteReader interface. The number of bytes transferred by each method is roughly balanced.
Types ¶
type AnonymousCloseWriter ¶
type AnonymousCloseWriter struct {
// contains filtered or unexported fields
}
func NewAnonymousCloseWriter ¶
func NewAnonymousCloseWriter(f func() error, w func(p []byte) (n int, err error)) *AnonymousCloseWriter
func (*AnonymousCloseWriter) Close ¶
func (inst *AnonymousCloseWriter) Close() error
type ByteBlockDiscardReaderI ¶
type ByteBlockDiscardReaderI interface {
ByteReadReaderI
Discard(n int) (int, error)
}
func NewByteBlockReaderDiscardReader ¶
func NewByteBlockReaderDiscardReader(reader any) (ByteBlockDiscardReaderI, error)
type ByteBlockWriterI ¶
type ByteBlockWriterI interface {
io.ByteWriter
io.Writer
}
type ByteReadReaderI ¶
type ByteReadReaderI interface {
io.Reader
io.ByteReader
}
type BytesBlockByteReadReader ¶
type BytesBlockByteReadReader struct {
// contains filtered or unexported fields
}
func NewBytesBlockByteReadReader ¶
func NewBytesBlockByteReadReader(r ByteReadReaderI) *BytesBlockByteReadReader
func (*BytesBlockByteReadReader) Discard ¶
func (inst *BytesBlockByteReadReader) Discard(n int) (nBytesRead int, err error)
func (*BytesBlockByteReadReader) Read ¶
func (inst *BytesBlockByteReadReader) Read(p []byte) (n int, err error)
func (*BytesBlockByteReadReader) ReadByte ¶
func (inst *BytesBlockByteReadReader) ReadByte() (byte, error)
type DeferredTee ¶
type DeferredTee struct {
// contains filtered or unexported fields
}
func NewDeferredTee ¶
func (*DeferredTee) Discard ¶
func (inst *DeferredTee) Discard(n int) (int, error)
Discard needs buffering, use DiscardAndFlush to stream directly to output.
func (*DeferredTee) DiscardAndFlush ¶
func (inst *DeferredTee) DiscardAndFlush(n int) (nWritten int, err error)
func (*DeferredTee) Flush ¶
func (inst *DeferredTee) Flush() (int, error)
func (*DeferredTee) ReadByte ¶
func (inst *DeferredTee) ReadByte() (b byte, err error)
type SizeMeasureWriter ¶
type SizeMeasureWriter struct {
Size uint64
}
func (*SizeMeasureWriter) Reset ¶
func (inst *SizeMeasureWriter) Reset()
type SplicingReader ¶
type SplicingReader struct {
// contains filtered or unexported fields
}
func NewSplicingReader ¶
func NewSplicingReader(primary io.Reader) *SplicingReader
func (*SplicingReader) IsSpliceReaderSet ¶
func (inst *SplicingReader) IsSpliceReaderSet() bool
func (*SplicingReader) Reset ¶
func (inst *SplicingReader) Reset()
func (*SplicingReader) SpliceReader ¶
func (inst *SplicingReader) SpliceReader(r io.Reader) (err error)
type TeeByteReader ¶
type TeeByteReader struct {
// contains filtered or unexported fields
}
func NewTeeByteReader ¶
func NewTeeByteReader(r ByteReadReaderI, w ByteBlockWriterI) *TeeByteReader
func (*TeeByteReader) ReadByte ¶
func (inst *TeeByteReader) ReadByte() (b byte, err error)
Source Files
Click to show internal directories.
Click to hide internal directories.