|
|
|
@@ -280,8 +280,9 @@ func notifyWatchers(e Engine, actions ...*Action) error { |
|
|
|
// NotifyWatchers creates batch of actions for every watcher. |
|
|
|
func NotifyWatchers(actions ...*Action) error { |
|
|
|
|
|
|
|
error := notifyWatchers(x, actions...) |
|
|
|
producer(actions...) |
|
|
|
return notifyWatchers(x, actions...) |
|
|
|
return error |
|
|
|
} |
|
|
|
|
|
|
|
func producer(actions ...*Action) { |
|
|
|
|