stream

package

v2.1.14 Latest Latest Go to latest Published: Feb 6, 2023 License: MIT Imports: 3 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/duke-git/lancet

Links

Open Source Insights

Documentation ¶

Overview ¶

Package stream implements a sequence of elements supporting sequential and parallel aggregate operations. this package is an experiment to explore if stream in go can work as the way java does. it's complete, but not powerful like other libs

Index ¶

func FromChannel[T any](source <-chan T) stream[T]
func FromRange[T constraints.Integer | constraints.Float](start, end, step T) stream[T]
func FromSlice[T any](source []T) stream[T]
func Generate[T any](generator func() func() (item T, ok bool)) stream[T]
func Of[T any](elems ...T) stream[T]

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FromChannel ¶

func FromChannel[T any](source <-chan T) stream[T]

FromChannel create stream from channel.

func FromRange ¶

func FromRange[T constraints.Integer | constraints.Float](start, end, step T) stream[T]

FromRange create a number stream from start to end. both start and end are included. [start, end]

func FromSlice ¶

func FromSlice[T any](source []T) stream[T]

FromSlice create stream from slice.

func Generate ¶

func Generate[T any](generator func() func() (item T, ok bool)) stream[T]

Generate stream where each element is generated by the provided generater function generater function: func() func() (item T, ok bool) {}

func Of ¶

func Of[T any](elems ...T) stream[T]

Of creates a stream stream whose elements are the specified values.

Types ¶

This section is empty.

Source Files ¶

View all Source files

stream.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL