Mercurial > gemma
changeset 5017:557afcd9a131
Curried functions all the way down. In this case a level too much. ;-)
author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
---|---|
date | Fri, 13 Mar 2020 18:04:14 +0100 |
parents | cf25b23e3eec |
children | d6873fa95ed6 |
files | pkg/imports/wx.go |
diffstat | 1 files changed, 15 insertions(+), 17 deletions(-) [+] |
line wrap: on
line diff
--- a/pkg/imports/wx.go Fri Mar 13 17:34:59 2020 +0100 +++ b/pkg/imports/wx.go Fri Mar 13 18:04:14 2020 +0100 @@ -25,7 +25,7 @@ newConsumer: newSQLConsumer( prepareStmnts(insertWaterwayAxisSQL), consume, - createAxisInvalidation(), + createAxisInvalidation, newMultiLineFeature(func() interface{} { return new(waterwayAxisProperties) }), @@ -81,21 +81,19 @@ ` ) -func createAxisInvalidation() func(*SQLGeometryConsumer) error { - return func(spc *SQLGeometryConsumer) error { - res, err := spc.tx.ExecContext(spc.ctx, invalidateAxisSQL) - if err != nil { - return err - } - old, err := res.RowsAffected() - if err != nil { - return err - } - if old == 0 { - return ErrFeaturesUnmodified - } - spc.feedback.Info( - "Number of features removed from data source: %d", old) - return nil +func createAxisInvalidation(spc *SQLGeometryConsumer) error { + res, err := spc.tx.ExecContext(spc.ctx, invalidateAxisSQL) + if err != nil { + return err } + old, err := res.RowsAffected() + if err != nil { + return err + } + if old == 0 { + return ErrFeaturesUnmodified + } + spc.feedback.Info( + "Number of features removed from data source: %d", old) + return nil }