add buffer for slice channel

173409900 · Mar 4, 2016 · 18a9077 · 18a9077
1 parent 280fdfb
commit 18a9077
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/dataset_source.go b/flow/dataset_source.go
@@ -94,7 +94,7 @@ func (fc *FlowContext) Slice(slice interface{}) (ret *Dataset) {
 	sliceValue, sliceType := reflect.ValueOf(slice), reflect.TypeOf(slice)
 	sliceLen := sliceValue.Len()
 	chType := reflect.ChanOf(reflect.BothDir, sliceType.Elem())
-	chValue := reflect.MakeChan(chType, 0)
+	chValue := reflect.MakeChan(chType, 16)
 
 	go func() {
 		for i := 0; i < sliceLen; i++ {