streams

Documentation

Index

• type Stream
  • func EmptyStream() Stream
  • func Of(i interface{}) Stream
• type Via

Types

type Stream

type Stream interface {
	Filter(predicate util.Predicate) Stream
	Map(function util.Function) Stream
	MapBreakable(function util.BreakableFunction) Stream
	FindAny() util.Optional
	Distinct() Stream
	Sorted(c util.Comparator) Stream
	Parallel(cnt uint) Stream
	Reverse() Stream
	ForEach(consumer util.Consumer)
	ForEachBreakable(function util.BreakableConsumer)
	Reduce(identity interface{}, op util.BinaryOperator) interface{}
	ToArray() interface{}
	Collect(collectors.Collector) interface{}
	Sum() float64
	Avg() float64
}

func EmptyStream

func EmptyStream() Stream

func Of

func Of(i interface{}) Stream

type Via

type Via interface {
	Via(streams.Flow) streams.Flow
	Out() <-chan interface{}
}