Merge pull request #223 from dmcgowan/fix-stream-failure

fuweid · web-flow · commit 9db9fcc5d28c · 2026-03-04T18:54:05.000-05:00
diff --git a/server.go b/server.go
@@ -413,6 +413,7 @@ func (c *serverConn) run(sctx context.Context) {
 					if !sendStatus(mh.StreamID, status.Newf(codes.InvalidArgument, "StreamID is no longer active")) {
 						return
 					}
+					continue
 				}
 				sh := i.(*streamHandler)
 				if mh.Flags&flagNoData != flagNoData {
@@ -426,6 +427,7 @@ func (c *serverConn) run(sctx context.Context) {
 						if !sendStatus(mh.StreamID, status.Newf(codes.InvalidArgument, "data handling error: %v", err)) {
 							return
 						}
+						continue
 					}
 				}
 
@@ -435,6 +437,7 @@ func (c *serverConn) run(sctx context.Context) {
 						if !sendStatus(mh.StreamID, status.Newf(codes.InvalidArgument, "data close message cannot include data")) {
 							return
 						}
+						continue
 					}
 				}
 			} else if mh.Type == messageTypeRequest {

Original file line number	Diff line number	Diff line change
`@@ -413,6 +413,7 @@ func (c *serverConn) run(sctx context.Context) {`
`413`	`413`	`if !sendStatus(mh.StreamID, status.Newf(codes.InvalidArgument, "StreamID is no longer active")) {`
`414`	`414`	`return`
`415`	`415`	`}`
	`416`	`+ continue`
`416`	`417`	`}`
`417`	`418`	`sh := i.(*streamHandler)`
`418`	`419`	`if mh.Flags&flagNoData != flagNoData {`
`@@ -426,6 +427,7 @@ func (c *serverConn) run(sctx context.Context) {`
`426`	`427`	`if !sendStatus(mh.StreamID, status.Newf(codes.InvalidArgument, "data handling error: %v", err)) {`
`427`	`428`	`return`
`428`	`429`	`}`
	`430`	`+ continue`
`429`	`431`	`}`
`430`	`432`	`}`
`431`	`433`
`@@ -435,6 +437,7 @@ func (c *serverConn) run(sctx context.Context) {`
`435`	`437`	`if !sendStatus(mh.StreamID, status.Newf(codes.InvalidArgument, "data close message cannot include data")) {`
`436`	`438`	`return`
`437`	`439`	`}`
	`440`	`+ continue`
`438`	`441`	`}`
`439`	`442`	`}`
`440`	`443`	`} else if mh.Type == messageTypeRequest {`