|
@@ -22,7 +22,6 @@ var (
|
|
|
type Data = interface{}
|
|
|
|
|
|
type opEntry struct {
|
|
|
- sync.Mutex
|
|
|
name string
|
|
|
inputs []*operation // still figuring, might be operation
|
|
|
executor interface{}
|
|
@@ -87,7 +86,7 @@ func (f *Flow) DefOp(id string, name string, params ...interface{}) Operation {
|
|
|
f.err = err
|
|
|
return opNil(f)
|
|
|
}
|
|
|
- f.operations.Store(id, &opEntry{sync.Mutex{}, name, inputs, executor})
|
|
|
+ f.operations.Store(id, &opEntry{name, inputs, executor})
|
|
|
return opFunc(f, id)
|
|
|
}
|
|
|
|
|
@@ -127,7 +126,7 @@ func (f *Flow) Op(name string, params ...interface{}) Operation {
|
|
|
if _, ok := f.operations.Load(id); ok {
|
|
|
continue
|
|
|
}
|
|
|
- f.operations.Store(id, &opEntry{sync.Mutex{}, name, inputs, executor})
|
|
|
+ f.operations.Store(id, &opEntry{name, inputs, executor})
|
|
|
return opFunc(f, id)
|
|
|
}
|
|
|
// Initialize opfunc maybe
|