diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2020-09-19 19:53:03 +0100 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2020-09-19 19:53:03 +0100 |
| commit | f7849d259668b408829f2b2e8d29b9753eff390a (patch) | |
| tree | 2e1dcee66abeef22a12c27e7a633baa27f2773fe /internal/clients/handlers/maprhandler.go | |
| parent | cdbcef72a1b9f93d08455b5a77f7f7afa2b9f53d (diff) | |
| parent | 3c889d2eed4e12af505ea84d46d8e52d21057a1f (diff) | |
Merge branch 'develop' of https://github.com/mimecast/dtail into develop
Diffstat (limited to 'internal/clients/handlers/maprhandler.go')
| -rw-r--r-- | internal/clients/handlers/maprhandler.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/internal/clients/handlers/maprhandler.go b/internal/clients/handlers/maprhandler.go index b908f3b..fb71c8f 100644 --- a/internal/clients/handlers/maprhandler.go +++ b/internal/clients/handlers/maprhandler.go @@ -3,6 +3,7 @@ package handlers import ( "strings" + "github.com/mimecast/dtail/internal" "github.com/mimecast/dtail/internal/io/logger" "github.com/mimecast/dtail/internal/mapr" "github.com/mimecast/dtail/internal/mapr/client" @@ -24,9 +25,7 @@ func NewMaprHandler(server string, query *mapr.Query, globalGroup *mapr.GlobalGr shellStarted: false, commands: make(chan string), status: -1, - withCancel: withCancel{ - done: make(chan struct{}), - }, + done: internal.NewDone(), }, query: query, aggregate: client.NewAggregate(server, query, globalGroup), |