From 1572aa06b2a38fd41e10dc901062413d0290d522 Mon Sep 17 00:00:00 2001 From: Pavol Rusnak Date: Sat, 11 Jun 2022 21:48:22 +0200 Subject: [PATCH] Don't defer close when the creation failed --- controllers/invoicestream.ctrl.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/controllers/invoicestream.ctrl.go b/controllers/invoicestream.ctrl.go index 6d2ae42..e65e5e8 100644 --- a/controllers/invoicestream.ctrl.go +++ b/controllers/invoicestream.ctrl.go @@ -49,10 +49,10 @@ func (controller *InvoiceStreamController) StreamInvoices(c echo.Context) error invoiceChan := make(chan models.Invoice) ticker := time.NewTicker(30 * time.Second) ws, done, err := createWebsocketUpgrader(c) - defer ws.Close() if err != nil { return err } + defer ws.Close() //start subscription subId, err := controller.svc.InvoicePubSub.Subscribe(strconv.FormatInt(userId, 10), invoiceChan) if err != nil {