From 68c5a9f9e54208d1f5e33a99c7ac278f543aacf4 Mon Sep 17 00:00:00 2001 From: Jack Chistyakov Date: Fri, 24 Apr 2026 19:44:05 -0600 Subject: [PATCH] Fix respons channel error handling --- core/transport/transport.go | 2 +- internal/socket/duplex.go | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/core/transport/transport.go b/core/transport/transport.go index d27791b..eb335ff 100644 --- a/core/transport/transport.go +++ b/core/transport/transport.go @@ -321,7 +321,7 @@ func (p *Transport) DispatchFrame(_ context.Context, frame core.BufferedFrame) ( // trigger handler err = handler(frame) if err != nil { - err = errors.Wrap(err, fmt.Sprintf("handle frame %s failed:", frame.Header().Type())) + err = errors.Wrap(err, fmt.Sprintf("handle frame %s failed:", t)) } return } diff --git a/internal/socket/duplex.go b/internal/socket/duplex.go index 1674d61..1d2d4f3 100644 --- a/internal/socket/duplex.go +++ b/internal/socket/duplex.go @@ -888,6 +888,8 @@ func (dc *DuplexConnection) onFrameError(input core.BufferedFrame) error { vv.pc.Error(err) case requestChannelCallback: vv.rcv.Error(err) + case respondChannelCallback: + vv.rcv.Error(err) default: return errors.Errorf("illegal value for error: %v", vv) }