stream

type Count struct {
	Count int64     `json:"count" xml:"count"`
	Start time.Time `json:"start" xml:"start"`
	End   time.Time `json:"end" xml:"end"`
}

type Item[T any] interface {
	// WithValue 设置元素值
	WithValue(value T) Item[T]
	// WithGroup 设置元素组
	WithGroup(group string) Item[T]
	// WithIndex 设置元素索引
	WithIndex(index uint64) Item[T]

	// GetValue 获取元素值
	GetValue() T
	// GetGroup 获取元素组
	GetGroup() string
	// GetIndex 获取元素索引
	GetIndex() uint64
}

type Stream[T any] interface {
	// Map 处理（异步）
	Map(mapFunc func(item Item[T]) T) Stream[T]
	// Group 分组（异步）
	Group(groupFunc func(item Item[T]) string) Stream[T]
	// Distinct 去重（异步）
	Distinct(distinctFunc func(item Item[T]) any) Stream[T]
	// Filter 过滤（异步）
	Filter(filterFunc func(item Item[T]) bool) Stream[T]
	// Concat 聚合（异步）
	Concat(streams ...Stream[T]) Stream[T]
	// Count 统计（异步）
	Count(interval time.Duration, countChan chan<- *Count) Stream[T]
	// Head 收前 num 个元素（异步）
	Head(num int) Stream[T]
	// Tail 收后 num 个元素（异步）
	Tail(num int) Stream[T]
	// SampleByStepSize 根据步长采样（异步）
	SampleByStepSize(size int64) Stream[T]
	// SampleByTime 根据时间采样（异步）
	SampleByTime(interval time.Duration) Stream[T]

	// Consume 一次性消费（异步）
	Consume(consumeFn func(item Item[T]))
	// Drain 丢弃数据（同步）
	Drain(doBeforeFns ...func(item Item[T]))
	// Receive 读取元素（同步）
	Receive() (Item[T], bool)
	// Channel 获取数据流管道
	Channel() <-chan Item[T]
}