stream

package

v0.0.2 Latest Latest Go to latest Published: Jan 20, 2025 License: MIT Imports: 0 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Stream[T any] struct {
	// contains filtered or unexported fields
}

Stream 提供类似Java Stream API的数据流操作

func StreamOf[T any](slice []T) *Stream[T]

StreamOf 从切片创建Stream

func (s *Stream[T]) AllMatch(predicate func(T) bool) bool

AllMatch 是否所有元素都匹配

func (s *Stream[T]) AnyMatch(predicate func(T) bool) bool

AnyMatch 是否存在匹配的元素

func (s *Stream[T]) Collect() []T

Collect 收集结果到切片

func (s *Stream[T]) Count() int

Count 计数

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

Distinct 去重

func (s *Stream[T]) Filter(predicate func(T) bool) *Stream[T]

Filter 过滤元素

func (s *Stream[T]) ForEach(consumer func(T))

ForEach 遍历元素

func (s *Stream[T]) Limit(n int) *Stream[T]

Limit 限制数量

func (s *Stream[T]) Map(mapper func(T) T) *Stream[T]

Map 转换元素

func (s *Stream[T]) Skip(n int) *Stream[T]

Skip 跳过元素