iterators

Aug 21, 2022

Changes in this version

+ func Reduce(i frameless.Iterator[T], initial Result, blk BLK) (rv Result, rErr error)

+ type BatchConfig struct

+ Size int

+ Timeout time.Duration

+ type BatchIter struct

+ Config BatchConfig

+ Iterator frameless.Iterator[T]

+ func Batch(i frameless.Iterator[T], c BatchConfig) *BatchIter[T]

+ func (i *BatchIter[T]) Close() error

+ func (i *BatchIter[T]) Err() error

+ func (i *BatchIter[T]) Init()

+ func (i *BatchIter[T]) Next() bool

+ func (i *BatchIter[T]) Value() []T

+ type FuncIter struct

+ NextFn func() (v T, more bool, err error)

+ func Func(next func() (v T, more bool, err error)) *FuncIter[T]

+ func (i *FuncIter[T]) Close() error

+ func (i *FuncIter[T]) Err() error

+ func (i *FuncIter[T]) Next() bool

+ func (i *FuncIter[T]) Value() T

Aug 14, 2022

Changes in this version

+ type ErrorIter struct

+ func (i *ErrorIter[T]) Close() error

+ func (i *ErrorIter[T]) Err() error

+ func (i *ErrorIter[T]) Next() bool

+ func (i *ErrorIter[T]) Value() T

+ type ISQLRows interface

+ Err func() error

+ Next func() bool

+ Scan func(dest ...interface{}) error

+ type SQLRowsIter struct

+ Mapper SQLRowMapper[T]

+ Rows ISQLRows

+ func (i *SQLRowsIter[T]) Close() error

+ func (i *SQLRowsIter[T]) Err() error

+ func (i *SQLRowsIter[T]) Next() bool

+ func (i *SQLRowsIter[T]) Value() T

+ type ScannerIter struct

+ Closer io.Closer

+ func (i *ScannerIter[T]) Close() error

+ func (i *ScannerIter[T]) Err() error

+ func (i *ScannerIter[T]) Next() bool

+ func (i *ScannerIter[T]) Value() T

+ type SingleValueIter struct

+ V T

+ func (i *SingleValueIter[T]) Close() error

+ func (i *SingleValueIter[T]) Err() error

+ func (i *SingleValueIter[T]) Next() bool

+ func (i *SingleValueIter[T]) Value() T

+ type SliceIter struct

+ Slice []T

+ func (i *SliceIter[T]) Close() error

+ func (i *SliceIter[T]) Err() error

+ func (i *SliceIter[T]) Next() bool

+ func (i *SliceIter[T]) Value() T

+ type StubIter struct

+ Iterator frameless.Iterator[T]

+ StubClose func() error

+ StubErr func() error

+ StubNext func() bool

+ StubValue func() T

+ func Stub(i frameless.Iterator[T]) *StubIter[T]

+ func (m *StubIter[T]) Close() error

+ func (m *StubIter[T]) Err() error

+ func (m *StubIter[T]) Next() bool

+ func (m *StubIter[T]) ResetClose()

+ func (m *StubIter[T]) ResetErr()

+ func (m *StubIter[T]) ResetNext()

+ func (m *StubIter[T]) ResetValue()

+ func (m *StubIter[T]) Value() T

May 15, 2022

Changes in this version

+ func Pipe() (*PipeIn[T], *PipeOut[T])

type ConcurrentAccessIterator

+ func (i *ConcurrentAccessIterator[T]) Value() T

+ type EmptyIter struct

+ func (i *EmptyIter[T]) Close() error

+ func (i *EmptyIter[T]) Err() error

+ func (i *EmptyIter[T]) Next() bool

+ func (i *EmptyIter[T]) Value() T

type Error

+ func (i *Error[T]) Value() T

+ type FilterIter struct

+ Filter func(T) bool

+ Iterator frameless.Iterator[T]

+ func (i *FilterIter[T]) Close() error

+ func (i *FilterIter[T]) Err() error

+ func (i *FilterIter[T]) Next() bool

+ func (i *FilterIter[T]) Value() T

type MapIter

+ Iterator frameless.Iterator[T]

+ Transform MapTransformFunc[T, V]

+ func (i *MapIter[T, V]) Value() V

type Mock

+ Iterator frameless.Iterator[T]

+ StubValue func() T

+ func (m *Mock[T]) ResetValue()

+ func (m *Mock[T]) Value() T

type PipeIn

+ DoneChan <-chan struct{}

+ ErrChan chan<- error

+ ValueChan chan<- T

+ func (f *PipeIn[T]) Value(v T) (ok bool)

type PipeOut

+ DoneChan chan<- struct{}

+ ErrChan <-chan error

+ ValueChan <-chan T

+ func (i *PipeOut[T]) Value() T

type SQLRowsIterator

+ Mapper SQLRowMapper[T]

+ Rows SQLRows

+ func (i *SQLRowsIterator[T]) Value() T

type Scanner

+ Reader io.Reader

+ func (i *Scanner[T]) Value() T

+ type SingleValue struct

+ V T

+ func NewSingleValue(v T) *SingleValue[T]

+ func (i *SingleValue[T]) Close() error

+ func (i *SingleValue[T]) Err() error

+ func (i *SingleValue[T]) Next() bool

+ func (i *SingleValue[T]) Value() T

type Slice

+ Slice []T

+ func (i *Slice[T]) Value() T

Jun 15, 2021

Changes in this version

+ type PipeIn struct

+ func (f *PipeIn) Close() error

+ func (f *PipeIn) Encode(e interface{}) error

+ func (f *PipeIn) Error(err error)

+ type PipeOut struct

+ func (i *PipeOut) Close() error

+ func (i *PipeOut) Decode(ptr interface{}) error

+ func (i *PipeOut) Err() error

+ func (i *PipeOut) Next() bool

Mar 11, 2020

Changes in this version

+ const Break

+ const ErrClosed

+ func Collect(i Interface, slicePtr interface{}) (err error)

+ func Count(i Interface) (int, error)

+ func First(i Interface, ptr interface{}) (found bool, err error)

+ func ForEach(i Interface, fn interface{}) (rErr error)

+ func Last(i Interface, e interface{}) (found bool, err error)

+ func NewPipe() (*PipeReceiver, *PipeSender)

+ type Callback struct

+ OnClose func(io.Closer) error

+ type CallbackIterator struct

+ func (i *CallbackIterator) Close() error

+ type ConcurrentAccessIterator struct

+ func WithConcurrentAccess(i Interface) *ConcurrentAccessIterator

+ func (i *ConcurrentAccessIterator) Decode(ptr interface{}) error

+ func (i *ConcurrentAccessIterator) Next() bool

+ type Decoder interface

+ Decode func(ptr interface{}) error

+ type DecoderFunc func(interface{}) error

+ func (lambda DecoderFunc) Decode(i interface{}) error

+ type Empty struct

+ func NewEmpty() *Empty

+ func (i *Empty) Close() error

+ func (i *Empty) Decode(interface{}) error

+ func (i *Empty) Err() error

+ func (i *Empty) Next() bool

+ type Encoder interface

+ Encode func(interface{}) error

+ type EncoderFunc func(interface{}) error

+ func (lambda EncoderFunc) Encode(i interface{}) error

+ type Error struct

+ func NewError(err error) *Error

+ func (i *Error) Close() error

+ func (i *Error) Decode(interface{}) error

+ func (i *Error) Err() error

+ func (i *Error) Next() bool

+ type FilterIterator struct

+ func Filter(i Interface, selectorFunc interface{}) *FilterIterator

+ func (fi *FilterIterator) Close() error

+ func (fi *FilterIterator) Decode(e interface{}) error

+ func (fi *FilterIterator) Err() error

+ func (fi *FilterIterator) Next() bool

+ type Interface interface

+ Err func() error

+ Next func() bool

+ func Errorf(format string, a ...interface{}) Interface

+ func WithCallback(i Interface, c Callback) Interface

+ type MapIter struct

+ func Map(iter Interface, transform MapTransformFunc) *MapIter

+ func (i *MapIter) Close() error

+ func (i *MapIter) Decode(dst interface{}) error

+ func (i *MapIter) Err() error

+ func (i *MapIter) Next() bool

+ type MapTransformFunc = func(d Decoder, ptr interface{}) error

+ type Mock struct

+ StubClose func() error

+ StubDecode func(interface{}) error

+ StubErr func() error

+ StubNext func() bool

+ func NewMock(i Interface) *Mock

+ func (m *Mock) Close() error

+ func (m *Mock) Decode(i interface{}) error

+ func (m *Mock) Err() error

+ func (m *Mock) Next() bool

+ func (m *Mock) ResetClose()

+ func (m *Mock) ResetDecode()

+ func (m *Mock) ResetErr()

+ func (m *Mock) ResetNext()

+ type PipeReceiver struct

+ func (i *PipeReceiver) Close() error

+ func (i *PipeReceiver) Decode(e interface{}) error

+ func (i *PipeReceiver) Err() error

+ func (i *PipeReceiver) Next() bool

+ type PipeSender struct

+ func (f *PipeSender) Close() error

+ func (f *PipeSender) Encode(e interface{}) error

+ func (f *PipeSender) Error(err error)

+ type SQLRowMapper interface

+ Map func(s SQLRowScanner, ptr interface{}) error

+ type SQLRowMapperFunc func(SQLRowScanner, interface{}) error

+ func (fn SQLRowMapperFunc) Map(s SQLRowScanner, e interface{}) error

+ type SQLRowScanner interface

+ Scan func(...interface{}) error

+ type SQLRows interface

+ Err func() error

+ Next func() bool

+ Scan func(dest ...interface{}) error

+ type SQLRowsIterator struct

+ func NewSQLRows(rows SQLRows, mapper SQLRowMapper) *SQLRowsIterator

+ func (i *SQLRowsIterator) Close() error

+ func (i *SQLRowsIterator) Decode(e interface{}) error

+ func (i *SQLRowsIterator) Err() error

+ func (i *SQLRowsIterator) Next() bool

+ type Scanner struct

+ func NewScanner(rc io.Reader) *Scanner

+ func (i *Scanner) Close() error

+ func (i *Scanner) Decode(container interface{}) error

+ func (i *Scanner) Err() error

+ func (i *Scanner) Next() bool

+ type SingleElement struct

+ func NewSingleElement(e interface{}) *SingleElement

+ func (i *SingleElement) Close() error

+ func (i *SingleElement) Decode(e interface{}) error

+ func (i *SingleElement) Err() error

+ func (i *SingleElement) Next() bool

+ type Slice struct

+ func NewSlice(slice interface{}) *Slice

+ func (i *Slice) Close() error

+ func (i *Slice) Decode(ptr interface{}) error

+ func (i *Slice) Err() error

+ func (i *Slice) Next() bool