Documentation ¶
Index ¶
- func AnyET[T comparable](ele []T, target T) bool
- func AwaitAll[R any](fns ...func() (R, error)) []*data[R]
- func AwaitAny[R any](fns ...func() (R, error)) *data[R]
- func AwaitRace[R any](fns ...func() (R, error)) R
- func CastOrNil[T any](el any) T
- func Copy[T any](v *T) *T
- func EvertET[T comparable](ele []T, target T) bool
- func EvertGET[T constraints.Ordered](ele []T, target T) bool
- func NewAsyncRoundTrip[R any, E any, T seqItem[R]]() *asyncRoundTrip[R, E, T]
- func NewAsyncSequence[R any](it AsyncSequenceable[R]) *asyncSequence[R]
- func NewAsyncSequenceIterator[T any](it Iterator[T]) *asyncSequenceIterator[T]
- func NewData[R any]() *data[R]
- func NewDataWith[R any](val R, err error) *data[R]
- func NewExecutablesList[R any]() *executablesList[R]
- func NewExecutor[R any]() *executable[R]
- func NewIterativeList[R any]() *iterativeList[R]
- func NewParallel[R any](maxWorkers int) *parallel[R]
- type Action
- type AsyncAdjacentFilterSequence
- func (a AsyncAdjacentFilterSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncAdjacentFilterSequence) EIter() <-chan *data[R]
- func (a AsyncAdjacentFilterSequence) Iter() <-chan R
- func (a AsyncAdjacentFilterSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- func (c *AsyncAdjacentFilterSequence[R]) SetPredicator(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- type AsyncAnySequence
- type AsyncBufferTimeSequence
- func (a AsyncBufferTimeSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncBufferTimeSequence) EIter() <-chan *data[R]
- func (a AsyncBufferTimeSequence) Iter() <-chan R
- func (a AsyncBufferTimeSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- func (a *AsyncBufferTimeSequence[R, T]) SetInterval(interval time.Duration) *AsyncBufferTimeSequence[R, T]
- type AsyncBufferedChan
- func (a AsyncBufferedChan) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a *AsyncBufferedChan[R]) Complete() *AsyncBufferedChan[R]
- func (a AsyncBufferedChan) EIter() <-chan *data[R]
- func (a AsyncBufferedChan) Iter() <-chan R
- func (a AsyncBufferedChan) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- type AsyncChannel
- func (a AsyncChannel) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a *AsyncChannel[R]) Complete() *AsyncChannel[R]
- func (a AsyncChannel) EIter() <-chan *data[R]
- func (a AsyncChannel) Iter() <-chan R
- func (a AsyncChannel) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- type AsyncCombineLatestSequence
- func CombineLatest[T1, T2 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2]) *AsyncCombineLatestSequence[Type2[T1, T2]]
- func CombineLatest3[T1, T2, T3 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2], ...) *AsyncCombineLatestSequence[Type3[T1, T2, T3]]
- func NewAsyncCombineLatestSequence[R any](its []iteratorAny) *AsyncCombineLatestSequence[R]
- func (a AsyncCombineLatestSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncCombineLatestSequence) EIter() <-chan *data[R]
- func (a AsyncCombineLatestSequence) Iter() <-chan R
- func (a AsyncCombineLatestSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- type AsyncCompactedSequence
- func (a AsyncCompactedSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncCompactedSequence) EIter() <-chan *data[R]
- func (a AsyncCompactedSequence) Iter() <-chan R
- func (a AsyncCompactedSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- func (c *AsyncCompactedSequence[R]) SetPredicator(fn func(R) bool) *AsyncCompactedSequence[R]
- type AsyncData
- type AsyncDebounceSequence
- func (a AsyncDebounceSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncDebounceSequence) EIter() <-chan *data[R]
- func (a AsyncDebounceSequence) Iter() <-chan R
- func (a AsyncDebounceSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- func (a *AsyncDebounceSequence[R]) SetInterval(interval time.Duration) *AsyncDebounceSequence[R]
- func (a *AsyncDebounceSequence[R]) SetTolerance(tolerance time.Duration) *AsyncDebounceSequence[R]
- type AsyncFlattenSequence
- type AsyncFns
- func (c *AsyncFns[R]) AddFns(fns ...func() (R, error)) *AsyncFns[R]
- func (a AsyncFns) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncFns) EIter() <-chan *data[R]
- func (a AsyncFns) Iter() <-chan R
- func (a AsyncFns) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- type AsyncInterval
- func (a AsyncInterval) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a *AsyncInterval[R]) Complete() *AsyncInterval[R]
- func (a AsyncInterval) EIter() <-chan *data[R]
- func (a AsyncInterval) Iter() <-chan R
- func (a AsyncInterval) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- type AsyncList
- type AsyncMapSequence
- func (a AsyncMapSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncMapSequence) EIter() <-chan *data[R]
- func (a AsyncMapSequence) Iter() <-chan R
- func (a AsyncMapSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- func (c *AsyncMapSequence[R, T]) SetPredicator(fn func(R) T) *AsyncMapSequence[R, T]
- type AsyncMergedSequence
- type AsyncMulticastConnector
- type AsyncMulticastSequence
- type AsyncPairwiseSequence
- type AsyncPartitionSequence
- func (a AsyncPartitionSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (a AsyncPartitionSequence) EIter() <-chan *data[R]
- func (a AsyncPartitionSequence) Iter() <-chan R
- func (a AsyncPartitionSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- func (a *AsyncPartitionSequence[R]) SetSize(size int) *AsyncPartitionSequence[R]
- type AsyncSequenceable
- type AsyncSubject
- func (a AsyncSubject) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
- func (c *AsyncSubject[R]) Complete() *AsyncSubject[R]
- func (a AsyncSubject) EIter() <-chan *data[R]
- func (c *AsyncSubject[R]) Error(err error) *AsyncSubject[R]
- func (a AsyncSubject) Iter() <-chan R
- func (a AsyncSubject) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
- func (c *AsyncSubject[R]) Next(val R) *AsyncSubject[R]
- type AsyncZipSequence
- func NewAsyncZipSequence[R any](its []iteratorAny) *AsyncZipSequence[R]
- func Zip[T1, T2 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2]) *AsyncZipSequence[Type2[T1, T2]]
- func Zip3[T1, T2, T3 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2], ...) *AsyncZipSequence[Type3[T1, T2, T3]]
- type CondCh
- type ErrorMode
- type Iterator
- type List
- type Optional
- type Type2
- type Type3
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AnyET ¶
func AnyET[T comparable](ele []T, target T) bool
func EvertET ¶
func EvertET[T comparable](ele []T, target T) bool
func EvertGET ¶
func EvertGET[T constraints.Ordered](ele []T, target T) bool
func NewAsyncRoundTrip ¶
func NewAsyncSequence ¶
func NewAsyncSequence[R any](it AsyncSequenceable[R]) *asyncSequence[R]
func NewDataWith ¶
func NewExecutablesList ¶
func NewExecutablesList[R any]() *executablesList[R]
func NewExecutor ¶
func NewExecutor[R any]() *executable[R]
func NewIterativeList ¶
func NewIterativeList[R any]() *iterativeList[R]
func NewParallel ¶
Types ¶
type Action ¶
type Action[E any] struct { // contains filtered or unexported fields }
func (*Action[E]) DiscardData ¶
type AsyncAdjacentFilterSequence ¶
type AsyncAdjacentFilterSequence[R any] struct { // contains filtered or unexported fields }
func NewAsyncAdjacentFilterSequence ¶
func NewAsyncAdjacentFilterSequence[R any](it AsyncSequenceable[R], fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncAdjacentFilterSequence) AdjacentFilter ¶
func (a AsyncAdjacentFilterSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncAdjacentFilterSequence) EIter ¶
func (a AsyncAdjacentFilterSequence) EIter() <-chan *data[R]
func (AsyncAdjacentFilterSequence) Merge ¶
func (a AsyncAdjacentFilterSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (*AsyncAdjacentFilterSequence[R]) SetPredicator ¶
func (c *AsyncAdjacentFilterSequence[R]) SetPredicator(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
type AsyncAnySequence ¶
type AsyncAnySequence[R any] struct { // contains filtered or unexported fields }
func NewAsyncAnySequence ¶
func NewAsyncAnySequence[R any](its ...AsyncSequenceable[R]) *AsyncAnySequence[R]
func (AsyncAnySequence) AdjacentFilter ¶
func (a AsyncAnySequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncAnySequence) Merge ¶
func (a AsyncAnySequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncBufferTimeSequence ¶
type AsyncBufferTimeSequence[R any, T []R] struct { // contains filtered or unexported fields }
func NewAsyncBufferTimeSequence ¶
func NewAsyncBufferTimeSequence[R any, T []R](it AsyncSequenceable[R], interval time.Duration) *AsyncBufferTimeSequence[R, T]
func (AsyncBufferTimeSequence) AdjacentFilter ¶
func (a AsyncBufferTimeSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncBufferTimeSequence) Merge ¶
func (a AsyncBufferTimeSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (*AsyncBufferTimeSequence[R, T]) SetInterval ¶
func (a *AsyncBufferTimeSequence[R, T]) SetInterval(interval time.Duration) *AsyncBufferTimeSequence[R, T]
type AsyncBufferedChan ¶
type AsyncBufferedChan[R any] struct { // contains filtered or unexported fields }
func FromChanBuffered ¶
func FromChanBuffered[R any](ch chan R) *AsyncBufferedChan[R]
func (AsyncBufferedChan) AdjacentFilter ¶
func (a AsyncBufferedChan) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (*AsyncBufferedChan[R]) Complete ¶
func (a *AsyncBufferedChan[R]) Complete() *AsyncBufferedChan[R]
func (AsyncBufferedChan) Merge ¶
func (a AsyncBufferedChan) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncChannel ¶
type AsyncChannel[R any] struct { // contains filtered or unexported fields }
func FromChan ¶
func FromChan[R any](ch chan R) *AsyncChannel[R]
func (AsyncChannel) AdjacentFilter ¶
func (a AsyncChannel) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (*AsyncChannel[R]) Complete ¶
func (a *AsyncChannel[R]) Complete() *AsyncChannel[R]
func (AsyncChannel) Merge ¶
func (a AsyncChannel) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncCombineLatestSequence ¶
type AsyncCombineLatestSequence[R any] struct { // contains filtered or unexported fields }
func CombineLatest ¶
func CombineLatest[T1, T2 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2]) *AsyncCombineLatestSequence[Type2[T1, T2]]
func CombineLatest3 ¶
func CombineLatest3[T1, T2, T3 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2], seq3 AsyncSequenceable[T3]) *AsyncCombineLatestSequence[Type3[T1, T2, T3]]
func NewAsyncCombineLatestSequence ¶
func NewAsyncCombineLatestSequence[R any](its []iteratorAny) *AsyncCombineLatestSequence[R]
func (AsyncCombineLatestSequence) AdjacentFilter ¶
func (a AsyncCombineLatestSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncCombineLatestSequence) EIter ¶
func (a AsyncCombineLatestSequence) EIter() <-chan *data[R]
func (AsyncCombineLatestSequence) Merge ¶
func (a AsyncCombineLatestSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncCompactedSequence ¶
type AsyncCompactedSequence[R comparable] struct { // contains filtered or unexported fields }
func NewAsyncCompactedSequence ¶
func NewAsyncCompactedSequence[R comparable](it AsyncSequenceable[R]) *AsyncCompactedSequence[R]
func (AsyncCompactedSequence) AdjacentFilter ¶
func (a AsyncCompactedSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncCompactedSequence) Merge ¶
func (a AsyncCompactedSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (*AsyncCompactedSequence[R]) SetPredicator ¶
func (c *AsyncCompactedSequence[R]) SetPredicator(fn func(R) bool) *AsyncCompactedSequence[R]
type AsyncData ¶
type AsyncData[R any] struct { // contains filtered or unexported fields }
func NewAsyncData ¶
func (*AsyncData[R]) IsComplete ¶
func (*AsyncData[R]) TransiteTo ¶
type AsyncDebounceSequence ¶
type AsyncDebounceSequence[R any] struct { // contains filtered or unexported fields }
func NewAsyncDebounceSequence ¶
func NewAsyncDebounceSequence[R any](it AsyncSequenceable[R], interval time.Duration) *AsyncDebounceSequence[R]
func (AsyncDebounceSequence) AdjacentFilter ¶
func (a AsyncDebounceSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncDebounceSequence) Merge ¶
func (a AsyncDebounceSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (*AsyncDebounceSequence[R]) SetInterval ¶
func (a *AsyncDebounceSequence[R]) SetInterval(interval time.Duration) *AsyncDebounceSequence[R]
func (*AsyncDebounceSequence[R]) SetTolerance ¶
func (a *AsyncDebounceSequence[R]) SetTolerance(tolerance time.Duration) *AsyncDebounceSequence[R]
type AsyncFlattenSequence ¶
type AsyncFlattenSequence[R any, T []R] struct { // contains filtered or unexported fields }
func NewAsyncFlattenSequence ¶
func NewAsyncFlattenSequence[R any, T []R](it AsyncSequenceable[T]) *AsyncFlattenSequence[R, T]
func (AsyncFlattenSequence) AdjacentFilter ¶
func (a AsyncFlattenSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncFlattenSequence) Merge ¶
func (a AsyncFlattenSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncFns ¶
type AsyncFns[R any] struct { // contains filtered or unexported fields }
func (AsyncFns) AdjacentFilter ¶
func (a AsyncFns) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncFns) Merge ¶
func (a AsyncFns) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncInterval ¶
type AsyncInterval[R any] struct { // contains filtered or unexported fields }
func Interval ¶
func Interval(period int) *AsyncInterval[int]
func (AsyncInterval) AdjacentFilter ¶
func (a AsyncInterval) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (*AsyncInterval[R]) Complete ¶
func (a *AsyncInterval[R]) Complete() *AsyncInterval[R]
func (AsyncInterval) Merge ¶
func (a AsyncInterval) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncList ¶
type AsyncList[R any] struct { // contains filtered or unexported fields }
func OfListWith ¶
func (AsyncList) AdjacentFilter ¶
func (a AsyncList) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncList) Merge ¶
func (a AsyncList) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncMapSequence ¶
type AsyncMapSequence[R, T any] struct { // contains filtered or unexported fields }
func NewAsyncMapSequence ¶
func NewAsyncMapSequence[R, T any](p AsyncSequenceable[R], fn func(R) T) *AsyncMapSequence[R, T]
func (AsyncMapSequence) AdjacentFilter ¶
func (a AsyncMapSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncMapSequence) Merge ¶
func (a AsyncMapSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (*AsyncMapSequence[R, T]) SetPredicator ¶
func (c *AsyncMapSequence[R, T]) SetPredicator(fn func(R) T) *AsyncMapSequence[R, T]
type AsyncMergedSequence ¶
type AsyncMergedSequence[R any] struct { // contains filtered or unexported fields }
func NewAsyncMergedSequence ¶
func NewAsyncMergedSequence[R any](as ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (AsyncMergedSequence) AdjacentFilter ¶
func (a AsyncMergedSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncMergedSequence) Merge ¶
func (a AsyncMergedSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncMulticastConnector ¶
type AsyncMulticastConnector[R any] struct { *AsyncMulticastSequence[R] // contains filtered or unexported fields }
func (AsyncMulticastConnector) AdjacentFilter ¶
func (a AsyncMulticastConnector) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncMulticastConnector) Merge ¶
func (a AsyncMulticastConnector) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncMulticastSequence ¶
type AsyncMulticastSequence[R any] struct { // contains filtered or unexported fields }
func NewAsyncMulticastSequence ¶
func NewAsyncMulticastSequence[R any](it AsyncSequenceable[R]) *AsyncMulticastSequence[R]
func (*AsyncMulticastSequence[R]) Connect ¶
func (a *AsyncMulticastSequence[R]) Connect() *AsyncMulticastConnector[R]
type AsyncPairwiseSequence ¶
type AsyncPairwiseSequence[R any, T []R] struct { // contains filtered or unexported fields }
func NewAsyncPairwiseSequence ¶
func NewAsyncPairwiseSequence[R any, T []R](it AsyncSequenceable[R]) *AsyncPairwiseSequence[R, T]
func (AsyncPairwiseSequence) AdjacentFilter ¶
func (a AsyncPairwiseSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncPairwiseSequence) Merge ¶
func (a AsyncPairwiseSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type AsyncPartitionSequence ¶
type AsyncPartitionSequence[R any] struct { // contains filtered or unexported fields }
func NewAsyncPartitionSequence ¶
func NewAsyncPartitionSequence[R any](size int, its ...AsyncSequenceable[R]) *AsyncPartitionSequence[R]
func (AsyncPartitionSequence) AdjacentFilter ¶
func (a AsyncPartitionSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncPartitionSequence) Merge ¶
func (a AsyncPartitionSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (*AsyncPartitionSequence[R]) SetSize ¶
func (a *AsyncPartitionSequence[R]) SetSize(size int) *AsyncPartitionSequence[R]
type AsyncSequenceable ¶
type AsyncSequenceable[R any] interface { // contains filtered or unexported methods }
type AsyncSubject ¶
type AsyncSubject[R any] struct { // contains filtered or unexported fields }
func NewAsyncSubject ¶
func NewAsyncSubject[R any]() *AsyncSubject[R]
func (AsyncSubject) AdjacentFilter ¶
func (a AsyncSubject) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (*AsyncSubject[R]) Complete ¶
func (c *AsyncSubject[R]) Complete() *AsyncSubject[R]
func (*AsyncSubject[R]) Error ¶
func (c *AsyncSubject[R]) Error(err error) *AsyncSubject[R]
func (AsyncSubject) Merge ¶
func (a AsyncSubject) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
func (*AsyncSubject[R]) Next ¶
func (c *AsyncSubject[R]) Next(val R) *AsyncSubject[R]
type AsyncZipSequence ¶
type AsyncZipSequence[R any] struct { // contains filtered or unexported fields }
func NewAsyncZipSequence ¶
func NewAsyncZipSequence[R any](its []iteratorAny) *AsyncZipSequence[R]
func Zip ¶
func Zip[T1, T2 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2]) *AsyncZipSequence[Type2[T1, T2]]
func Zip3 ¶
func Zip3[T1, T2, T3 any](seq1 AsyncSequenceable[T1], seq2 AsyncSequenceable[T2], seq3 AsyncSequenceable[T3]) *AsyncZipSequence[Type3[T1, T2, T3]]
func (AsyncZipSequence) AdjacentFilter ¶
func (a AsyncZipSequence) AdjacentFilter(fn func(R, R) bool) *AsyncAdjacentFilterSequence[R]
func (AsyncZipSequence) Merge ¶
func (a AsyncZipSequence) Merge(its ...AsyncSequenceable[R]) *AsyncMergedSequence[R]
type Iterator ¶
type Iterator[T any] interface { Iter() <-chan T EIter() <-chan *data[T] // contains filtered or unexported methods }
type Optional ¶
type Optional[R any] struct { // contains filtered or unexported fields }
func NewOptionalEmpty ¶
func OptionalIf ¶
func OptionalOf ¶
func (Optional[R]) AsOptional ¶
Source Files ¶
- action.go
- action_await_all.go
- action_await_race.go
- async_adjacent_filter_sequence.go
- async_any_sequence.go
- async_buffer_time_sequence.go
- async_combine_latest_sequence.go
- async_compacted_sequence.go
- async_data.go
- async_debounce_sequence.go
- async_flatten_sequence.go
- async_list.go
- async_map_sequence.go
- async_merged_sequence.go
- async_multicast_sequence.go
- async_pairwise_sequence.go
- async_partition_sequence.go
- async_round_trip.go
- async_sequence.go
- async_sequenceable.go
- async_subject.go
- async_types.go
- async_zip_sequence.go
- cond_ch.go
- data.go
- executable.go
- from_chan.go
- from_chan_buffered.go
- from_fn.go
- interval.go
- of_list.go
- optional.go
- parallel.go
- utils.go
Click to show internal directories.
Click to hide internal directories.