From 6ec900d07b4c792067358b0aae55a62305700a2e Mon Sep 17 00:00:00 2001 From: Teo Mrnjavac Date: Fri, 9 Sep 2022 11:35:06 +0200 Subject: [PATCH] Fix bug with error being shadowed in Client.Start() --- client.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/client.go b/client.go index 56ad290..42a6ba1 100644 --- a/client.go +++ b/client.go @@ -66,12 +66,12 @@ func (client *Client) doSubscribe(topic string, fn interface{}, serverAddr, serv } } -//Subscribe subscribes to a topic in a remote event bus +// Subscribe subscribes to a topic in a remote event bus func (client *Client) Subscribe(topic string, fn interface{}, serverAddr, serverPath string) { client.doSubscribe(topic, fn, serverAddr, serverPath, Subscribe) } -//SubscribeOnce subscribes once to a topic in a remote event bus +// SubscribeOnce subscribes once to a topic in a remote event bus func (client *Client) SubscribeOnce(topic string, fn interface{}, serverAddr, serverPath string) { client.doSubscribe(topic, fn, serverAddr, serverPath, SubscribeOnce) } @@ -84,12 +84,13 @@ func (client *Client) Start() error { server := rpc.NewServer() server.Register(service) server.HandleHTTP(client.path, "/debug"+client.path) - l, err := net.Listen("tcp", client.address) + var l net.Listener + l, err = net.Listen("tcp", client.address) if err == nil { service.wg.Add(1) service.started = true - go http.Serve(l, nil) - } + go http.Serve(l, nil) + } } else { err = errors.New("Client service already started") }