diff --git a/pkg/services/rpcsrv/server.go b/pkg/services/rpcsrv/server.go index 1899a0ee1..6531ccaf8 100644 --- a/pkg/services/rpcsrv/server.go +++ b/pkg/services/rpcsrv/server.go @@ -470,7 +470,7 @@ func (s *Server) handleHTTPRequest(w http.ResponseWriter, httpRequest *http.Requ } resChan := make(chan abstractResult) // response.abstract or response.abstractBatch subChan := make(chan intEvent, notificationBufSize) - subscr := &subscriber{writer: subChan, ws: ws} + subscr := &subscriber{writer: subChan} s.subsLock.Lock() s.subscribers[subscr] = true s.subsLock.Unlock() diff --git a/pkg/services/rpcsrv/subscription.go b/pkg/services/rpcsrv/subscription.go index 306c27f26..511aed2ef 100644 --- a/pkg/services/rpcsrv/subscription.go +++ b/pkg/services/rpcsrv/subscription.go @@ -17,7 +17,6 @@ type ( // subscriber is an event subscriber. subscriber struct { writer chan<- intEvent - ws *websocket.Conn overflown atomic.Bool // These work like slots as there is not a lot of them (it's // cheaper doing it this way rather than creating a map),