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) }