gostream

Oct 25, 2019

Changes in this version

type Stream

+ func (stream *Stream) GroupByToMap(FieldName string) map[string][]interface{}

+ func (stream *Stream) GroupByToStream(FieldName string) map[string]*Stream

Oct 25, 2019

Changes in this version

type Stream

+ func (stream *Stream) GroupBy(FieldName string) map[string]*Stream

+ type StreamManager struct

Sep 26, 2019

Changes in this version

type Stream

+ func (stream *Stream) Copy() *Stream

+ func (stream *Stream) Distinct() *Stream

+ type Unique interface

+ HashCode func() []byte

Sep 25, 2019

Changes in this version

+ type Stream struct

+ func BuildStream(array interface{}) *Stream

+ func (stream *Stream) Collect() interface{}

+ func (stream *Stream) Combine(anotherStream *Stream) *Stream

+ func (stream *Stream) Filter(f func(interface{}) bool) *Stream

+ func (stream *Stream) Limit(len int) *Stream

+ func (stream *Stream) Map(f func(interface{}) interface{}) *Stream

+ func (stream *Stream) MultipartMap(worknum int, f func(interface{}) interface{}) *Stream

+ func (stream *Stream) Reduce(f func(interface{}, interface{}) interface{}) interface{}

+ func (stream *Stream) Sorted() *Stream