File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -3,8 +3,9 @@ package executor
33import (
44 "errors"
55
6- "go.uber.org/cadence/internal"
76 "go.uber.org/multierr"
7+
8+ "go.uber.org/cadence/internal"
89)
910
1011type Executor interface {
@@ -21,7 +22,7 @@ type batchExecutor struct {
2122}
2223
2324type futureWithResult struct {
24- future internal.Future
25+ future internal.Future
2526 valuePtr interface {}
2627}
2728
@@ -70,7 +71,7 @@ func (e *batchExecutor) Execute(ctx internal.Context) error {
7071 for i := range e .factories {
7172 buffered .Send (ctx , nil )
7273 futuresToProcess .Send (ctx , futureWithResult {
73- future : e.factories [i ](ctx ),
74+ future : e.factories [i ](ctx ),
7475 valuePtr : e .valuePtrs [i ],
7576 })
7677 }
@@ -83,7 +84,7 @@ func (e *batchExecutor) Execute(ctx internal.Context) error {
8384 return errs
8485}
8586
86- func NewBatchExecutor (ctx internal.Context ,batchSize int ) Executor {
87+ func NewBatchExecutor (ctx internal.Context , batchSize int ) Executor {
8788 return & batchExecutor {
8889 batchSize : batchSize ,
8990 }
You can’t perform that action at this time.
0 commit comments