yale8848 / stream Goto Github PK

   var data =[]person{{age:11,name:"alice"},{age:19,name:"pig"},{age:5,name:"cat"},{age:21,name:"bob"}}
   
   st,_:=stream.Of(data)
   st.Filter(func(v stream.T) bool {
   		p:=v.(person)
   		fmt.Printf("Filter %v\r\n",v)
   		return  p.age>10
   	}).Peek(func(v stream.T) {
   		fmt.Printf("Peek %v\r\n",v)
   	}).Skip(1).Map(func(v stream.T) stream.T {
   		p:=v.(person)
   		p.name = strings.ToUpper(p.name)
   		return p
   	}).Sorted(func(v1, v2 stream.T) bool {
   		s1:=v1.(person)
   		s2:=v2.(person)
   		return  strings.Compare(s1.name,s2.name)<0
   	}).Limit(2).Distinct(func(v stream.T) stream.T {
   		p:=v.(person)
   		fmt.Printf("Distinct %v\r\n",v)
   		return p.name
   	}).ForEach(func(v stream.T) bool {
      		fmt.Printf("ForEach %v\r\n",v)
      		return true
      	})