diff --git a/sampi/client/client.go b/sampi/client/client.go
index <HASH>..<HASH> 100644
--- a/sampi/client/client.go
+++ b/sampi/client/client.go
@@ -18,6 +18,7 @@ func New() (*Client, error) {
 	if err != nil {
 		return nil, err
 	}
+	defer services.Close()
 	select {
 	case <-services.Watch(true, true):
 	case <-time.After(time.Second):
host/sampi: client: Close service stream after we're done with it