Commite3f8508

committed

close sendCh after sending stop response

1 parentbc5fe4e commite3f8508Copy full SHA for e3f8508

File tree

-5

lines changed

-5

lines changed

Lines changed: 1 addition & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -103,11 +103,7 @@ func (t *Tunnel) requestLoop() {`
`103`	`103`	`ifreq.msg.Rpc!=nil&&req.msg.Rpc.MsgId!=0 {`
`104`	`104`	`t.handleRPC(req)`
`105`	`105`	`if_,ok:=req.msg.GetMsg().(*ManagerMessage_Stop);ok {`
`106`		`-// TODO: Wait for the reply to be sent before closing the speaker.`
`107`		`-// err := t.speaker.Close()`
`108`		`-// if err != nil {`
`109`		`-// t.logger.Error(t.ctx, "failed to close speaker", slog.Error(err))`
`110`		`-// }`
	`106`	`+close(t.sendCh)`
`111`	`107`	`return`
`112`	`108`	`}`
`113`	`109`	`continue`

Comments

(0)