Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var BackgroundContext = context.Background()
use internally for iterations we know are cannot block. USE WITH CAUTION
Functions ¶
func MergeErrors ¶ added in v0.8.5
Types ¶
type ChannelIterImpl ¶
type ChannelIterImpl[T any] struct { Pipe <-chan T Error error Ctx context.Context Closer context.CancelFunc WG sync.WaitGroup // contains filtered or unexported fields }
func (*ChannelIterImpl[T]) Close ¶
func (iter *ChannelIterImpl[T]) Close() error
func (*ChannelIterImpl[T]) Value ¶
func (iter *ChannelIterImpl[T]) Value() T
type GeneratorIterator ¶ added in v0.8.5
type GeneratorIterator[T any] struct { Operation func(context.Context) (T, error) Closer context.CancelFunc Error error // contains filtered or unexported fields }
func (*GeneratorIterator[T]) Close ¶ added in v0.8.5
func (iter *GeneratorIterator[T]) Close() error
func (*GeneratorIterator[T]) Next ¶ added in v0.8.5
func (iter *GeneratorIterator[T]) Next(ctx context.Context) bool
func (*GeneratorIterator[T]) Value ¶ added in v0.8.5
func (iter *GeneratorIterator[T]) Value() T
type MergedError ¶ added in v0.6.1
func (*MergedError) As ¶ added in v0.6.1
func (dwe *MergedError) As(target any) bool
func (*MergedError) Error ¶ added in v0.6.1
func (dwe *MergedError) Error() string
func (*MergedError) Is ¶ added in v0.6.1
func (dwe *MergedError) Is(target error) bool
func (*MergedError) Unwrap ¶ added in v0.6.1
func (dwe *MergedError) Unwrap() error
type SliceIterImpl ¶
func NewSliceIter ¶ added in v0.6.3
func NewSliceIter[T any](in []T) *SliceIterImpl[T]
func (*SliceIterImpl[T]) Close ¶
func (iter *SliceIterImpl[T]) Close() error
func (*SliceIterImpl[T]) Value ¶
func (iter *SliceIterImpl[T]) Value() T
Click to show internal directories.
Click to hide internal directories.