From 3e556edb2dbe7345d8e22d223c9cba651bcae4b3 Mon Sep 17 00:00:00 2001 From: Graham Barr Date: Fri, 23 May 2014 08:00:58 -0500 Subject: [PATCH] When a job completes, remove its handler --- client/client.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/client/client.go b/client/client.go index b98dffe..b2a8c00 100644 --- a/client/client.go +++ b/client/client.go @@ -145,10 +145,8 @@ func (client *Client) processLoop() { case dtWorkData, dtWorkWarning, dtWorkStatus: resp = client.handleResponse(resp.Handle, resp) case dtWorkComplete, dtWorkFail, dtWorkException: - resp = client.handleResponse(resp.Handle, resp) - if resp != nil { - delete(client.respHandler, resp.Handle) - } + client.handleResponse(resp.Handle, resp) + delete(client.respHandler, resp.Handle) } } }