From f85b537eedb68a81dfa48506cf50308b1fcb3ed5 Mon Sep 17 00:00:00 2001 From: "Zane.Y" Date: Wed, 19 Jul 2017 11:35:46 +0800 Subject: [PATCH 1/2] Update README.md --- README.md | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) 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 @@

本工具包提供的并发数据流在处理压力较低或者单核机器上时,并发处理为负优化,请斟酌选择是否并发


Usage: +

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.

From c867254ad201fc8a15135a0d313b9520e90c35fb Mon Sep 17 00:00:00 2001 From: "Zane.Y" Date: Wed, 19 Jul 2017 11:46:28 +0800 Subject: [PATCH 2/2] package location --- main/main.go | 2 +- stream/collectors/groupingBy.go | 2 +- stream/collectors/partitioningBy.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/main/main.go b/main/main.go index 47b6fd9..6a90d89 100644 --- a/main/main.go +++ b/main/main.go @@ -1,7 +1,7 @@ package main import ( - . "github.com/go-func/stream" + . "github.com/ZaneYork/go-func/stream" ) // func NewStopWatch() func() time.Duration { 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 {