From b33c6c77dd9ce06c7349a490a7602f769e06c15f Mon Sep 17 00:00:00 2001 From: Sarah Jamie Lewis Date: Tue, 22 Jun 2021 15:34:46 -0700 Subject: [PATCH] Remove Unused Map --- utils/eventHandler.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/utils/eventHandler.go b/utils/eventHandler.go index 978fb49..cd439f0 100644 --- a/utils/eventHandler.go +++ b/utils/eventHandler.go @@ -23,11 +23,10 @@ type EventHandler struct { app app.Application appBusQueue event.Queue profileEvents chan EventProfileEnvelope - profileQueues map[string]event.Queue } func NewEventHandler() *EventHandler { - eh := &EventHandler{app: nil, appBusQueue: event.NewQueue(), profileQueues: make(map[string]event.Queue), profileEvents: make(chan EventProfileEnvelope)} + eh := &EventHandler{app: nil, appBusQueue: event.NewQueue(), profileEvents: make(chan EventProfileEnvelope)} return eh } @@ -345,7 +344,6 @@ func (eh *EventHandler) startHandlingPeer(onion string) { eventBus.Subscribe(event.ChangePasswordError, q) eventBus.Subscribe(event.NewRetValMessageFromPeer, q) eventBus.Subscribe(event.SetAttribute, q) - eh.profileQueues[onion] = q go eh.forwardProfileMessages(onion, q) @@ -357,6 +355,9 @@ func (eh *EventHandler) forwardProfileMessages(onion string, q event.Queue) { e := q.Next() ev := EventProfileEnvelope{Event: e, Profile: onion} eh.profileEvents <- ev + if ev.Event.EventType == event.Shutdown { + return + } } }