Fix respons channel error handling (#149)

echistyakov · web-flow · commit 2a2c1cfad8a9 · 2026-04-29T10:10:26.000+08:00
diff --git 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
@@ -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)
 	}

Original file line number	Diff line number	Diff line change
`@@ -321,7 +321,7 @@ func (p *Transport) DispatchFrame(_ context.Context, frame core.BufferedFrame) (`
`321`	`321`	`// trigger handler`
`322`	`322`	`err = handler(frame)`
`323`	`323`	`if err != nil {`
`324`		`- err = errors.Wrap(err, fmt.Sprintf("handle frame %s failed:", frame.Header().Type()))`
	`324`	`+ err = errors.Wrap(err, fmt.Sprintf("handle frame %s failed:", t))`
`325`	`325`	`}`
`326`	`326`	`return`
`327`	`327`	`}`
Original file line number	Diff line number	Diff line change
`@@ -888,6 +888,8 @@ func (dc *DuplexConnection) onFrameError(input core.BufferedFrame) error {`
`888`	`888`	`vv.pc.Error(err)`
`889`	`889`	`case requestChannelCallback:`
`890`	`890`	`vv.rcv.Error(err)`
	`891`	`+ case respondChannelCallback:`
	`892`	`+ vv.rcv.Error(err)`
`891`	`893`	`default:`
`892`	`894`	`return errors.Errorf("illegal value for error: %v", vv)`
`893`	`895`	`}`