diff --git a/README.md b/README.md index bc74eba..96ac539 100644 --- a/README.md +++ b/README.md @@ -3,8 +3,10 @@
Provide functional programming interface in golang
使用指南: +0.拉取工具包
+go get github.com/ZaneYork/go-func/stream
1.引入工具包:
-import . "github.com/go-func/stream"
import . "github.com/ZaneYork/go-func/stream"
2.使用NewSteam
或者NewParallelStream
函数开启数据流
3.然后追加流操作函数以修改数据
4.使用如Collect、Reduce等流终结操作函数拿到处理结果集
@@ -12,8 +14,10 @@本工具包提供的并发数据流在处理压力较低或者单核机器上时,并发处理为负优化,请斟酌选择是否并发
0.Clone source code
+go get github.com/ZaneYork/go-func/stream
1.import package:
-import . "github.com/go-func/stream"
import . "github.com/ZaneYork/go-func/stream"
2.Start steam with function NewSteam
or NewParallelStream
3.Append operation function to modify element in stream
4.Terminate stream with any termination operation like Collect,Reduce,etc.
diff --git a/stream/collectors/groupingBy.go b/stream/collectors/groupingBy.go index 8dc65a2..038bd6c 100644 --- a/stream/collectors/groupingBy.go +++ b/stream/collectors/groupingBy.go @@ -1,6 +1,6 @@ package collectors -import . "github.com/go-func/stream" +import . "github.com/ZaneYork/go-func/stream" // GroupingBy 按照指定的规则分组 type GroupingBy struct { diff --git a/stream/collectors/partitioningBy.go b/stream/collectors/partitioningBy.go index 4689225..8e850bd 100644 --- a/stream/collectors/partitioningBy.go +++ b/stream/collectors/partitioningBy.go @@ -1,6 +1,6 @@ package collectors -import . "github.com/go-func/stream" +import . "github.com/ZaneYork/go-func/stream" // PartitioningBy 按照指定的分区 type PartitioningBy struct {