Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IONextReader ¶
type IONextReader struct {
LengthDelim bool
// contains filtered or unexported fields
}
note that IONextReader will always close the underlying reader when exiting. It must do that to exit the ReadNext blocking call
func (IONextReader) ReadNext ¶
func (rn IONextReader) ReadNext() (next []byte, is_eof bool, err error)
func (IONextReader) Stop ¶
func (rn IONextReader) Stop()
type InterfaceReader ¶
type InterfaceReaderSource ¶
type InterfaceReaderSource struct {
*stream.HardStopChannelCloser
*stream.BaseOut
// contains filtered or unexported fields
}
func (InterfaceReaderSource) Run ¶
func (src InterfaceReaderSource) Run() error
type NextReader ¶
type NextReader interface {
//ReadNext should/can block until Stop Called
ReadNext() (next []byte, is_eof bool, err error)
Stop()
}
func NewIOReaderWrapper ¶
func NewIOReaderWrapper(r io.ReadCloser) NextReader
func NewIOReaderWrapperLengthDelim ¶
func NewIOReaderWrapperLengthDelim(r io.ReadCloser) NextReader
type NextReaderSource ¶
type NextReaderSource struct {
*stream.HardStopChannelCloser
*stream.BaseOut
MaxItems uint32
// contains filtered or unexported fields
}
func (*NextReaderSource) Run ¶
func (src *NextReaderSource) Run() error
func (*NextReaderSource) Stop ¶
func (src *NextReaderSource) Stop() error
type Sourcer ¶
func NewIOReaderSource ¶
func NewIOReaderSource(reader io.ReadCloser) Sourcer
func NewIOReaderSourceLengthDelim ¶
func NewIOReaderSourceLengthDelim(reader io.ReadCloser) Sourcer
func NewInterfaceReaderSource ¶
func NewInterfaceReaderSource(reader InterfaceReader) Sourcer
func NewNextReaderSource ¶
func NewNextReaderSource(reader NextReader) Sourcer
func NewNextReaderSourceMax ¶
func NewNextReaderSourceMax(reader NextReader, max uint32) Sourcer
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.