stream

Documentation

Overview

Package stream is data stream ETL

Index

• type Stream
  • func Connect[T comparable](arr []T, arrs ...[]T) Stream[T]
  • func New[T comparable](arr []T) Stream[T]
  • func Of[T comparable](obj ...T) Stream[T]
  • func (s Stream[T]) Distinct() Stream[T]
  • func (s Stream[T]) Each(fn func(i int, o T))
  • func (s Stream[T]) Filter(fn func(o T) bool) Stream[T]
  • func (s Stream[T]) Limit(n uint) Stream[T]
  • func (s Stream[T]) List() (arr []T)
  • func (s Stream[T]) Reverse() Stream[T]
  • func (s Stream[T]) Skip(n uint) Stream[T]

Types

type Stream

type Stream[T comparable] chan T

func Connect

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

Connect Multiple slice splicing

func New

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

New slice to stream

func Of

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

Of element to stream

func (Stream[T]) Distinct

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

Distinct 去重

func (Stream[T]) Each

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

Each for every element

func (Stream[T]) Filter

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

Filter 过滤

func (Stream[T]) Limit

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

func (Stream[T]) List

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

List stream to slice

func (Stream[T]) Reverse

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

Reverse 数据反转

func (Stream[T]) Skip

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