diff options
Diffstat (limited to 'internal/server/handlers/mapcommand.go')
| -rw-r--r-- | internal/server/handlers/mapcommand.go | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/internal/server/handlers/mapcommand.go b/internal/server/handlers/mapcommand.go index 10372da..c3e600e 100644 --- a/internal/server/handlers/mapcommand.go +++ b/internal/server/handlers/mapcommand.go @@ -15,18 +15,16 @@ type mapCommand struct { // NewMapCommand returns a new server side mapreduce command. func newMapCommand(serverHandler *ServerHandler, argc int, args []string) (mapCommand, *server.Aggregate, error) { - mapCommand := mapCommand{ - server: serverHandler, - } + m := mapCommand{server: serverHandler} queryStr := strings.Join(args[1:], " ") aggregate, err := server.NewAggregate(queryStr) if err != nil { - return mapCommand, nil, err + return m, nil, err } - mapCommand.aggregate = aggregate - return mapCommand, aggregate, nil + m.aggregate = aggregate + return m, aggregate, nil } |