diff --git a/app/proxyman/mux/mux.go b/app/proxyman/mux/mux.go index 6d6fabe6a..89b125523 100644 --- a/app/proxyman/mux/mux.go +++ b/app/proxyman/mux/mux.go @@ -107,7 +107,7 @@ func NewClient(p proxy.Outbound, dialer proxy.Dialer, m *ClientManager) (*Client if err := p.Process(ctx, &core.Link{Reader: uplinkReader, Writer: downlinkWriter}, dialer); err != nil { errors.New("failed to handler mux client connection").Base(err).WriteToLog() } - c.done.Close() + common.Must(c.done.Close()) cancel() }() @@ -253,7 +253,7 @@ func (m *Client) handleStatusEnd(meta *FrameMetadata, reader *buf.BufferedReader } func (m *Client) fetchOutput() { - defer m.done.Close() + defer common.Must(m.done.Close()) reader := buf.NewBufferedReader(m.link.Reader)