stream

package

v0.1.2 Latest Latest Go to latest Published: Mar 14, 2025 License: BSD-3-Clause Imports: 0 Imported by: 0

Details

Package stream is data stream ETL

This section is empty.

This section is empty.

This section is empty.

type Stream[T comparable] chan T

func Connect[T comparable](arr []T, arrs ...[]T) Stream[T]

Connect Multiple slice splicing

func New[T comparable](arr []T) Stream[T]

New slice to stream

func Of[T comparable](obj ...T) Stream[T]

Of element to stream

func (s Stream[T]) Distinct() Stream[T]

Distinct 去重

func (s Stream[T]) DistinctFn(fn func(o T) any) Stream[T]

DistinctFn 去重

func (s Stream[T]) Each(fn func(i int, o T))

Each for every element

func (s Stream[T]) Filter(fn func(o T) bool) Stream[T]

Filter 过滤

func (s Stream[T]) Limit(n uint) Stream[T]

func (s Stream[T]) Reverse() Stream[T]

Reverse 数据反转

func (s Stream[T]) Skip(n uint) Stream[T]

func (s Stream[T]) Slice() (arr []T)

Slice stream to slice