added defer to outer func

bluzelle · Jul 31, 2021 · ccc7f51 · ccc7f51
1 parent 6a207c6
commit ccc7f51
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/x/curium/keeper/keeper.go b/x/curium/keeper/keeper.go
@@ -125,13 +125,16 @@ func (k Keeper) NewMsgBroadcaster(keyringDir string, cdc *codec.Codec) MsgBroadc
 	return func(ctx sdk.Context, msgs []sdk.Msg, from string) chan *MsgBroadcasterResponse {
 		resp := make(chan *MsgBroadcasterResponse)
 
+		defer func () {
+			close(resp)
+		}()
+
 		go func() {
 
 			returnError := func(err error) {
 				resp <- &MsgBroadcasterResponse{
 					Error: err,
 				}
-				close(resp)
 			}
 
 			defer func () {
@@ -241,7 +244,7 @@ func (k Keeper) NewMsgBroadcaster(keyringDir string, cdc *codec.Codec) MsgBroadc
 			}
 			fmt.Println("Break 8")
 
-			close(resp)
+
 
 		}()