From 6359da32962fea3334116798fddc552e5073bb69 Mon Sep 17 00:00:00 2001 From: Eichin David Date: Fri, 24 Oct 2014 23:25:56 +0200 Subject: [PATCH] fixed missing live console output bug on rebuild --- server/worker/docker/docker.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/worker/docker/docker.go b/server/worker/docker/docker.go index ad1f3bf50..d00f77521 100644 --- a/server/worker/docker/docker.go +++ b/server/worker/docker/docker.go @@ -68,7 +68,7 @@ func (d *Docker) Do(c context.Context, r *worker.Work) { commitc := pubsub.Register(c, "_global") commitc.Publish(r) stdoutc := pubsub.RegisterOpts(c, r.Commit.ID, pubsub.ConsoleOpts) - defer stdoutc.Close() + defer pubsub.Unregister(c, r.Commit.ID) // create a special buffer that will also // write to a websocket channel