diff --git a/internal/pkg/afrouter/request.go b/internal/pkg/afrouter/request.go
index 8fc15aa..dbd9968 100644
--- a/internal/pkg/afrouter/request.go
+++ b/internal/pkg/afrouter/request.go
@@ -66,7 +66,10 @@
 		}
 	}
 	if r.sendClosed {
-		stream.CloseSend()
+		err := stream.CloseSend()
+		if err != nil {
+			log.Errorf("%v", err)
+		}
 	}
 
 	r.mutex.Unlock()
@@ -111,9 +114,9 @@
 					if err = r.sendResponseFrame(stream, frame); err != nil {
 						break
 					}
-				} else { // !activeStream && !r.isStreamingRequest && !r.isStreamingResponse
-					// just read & discard until the stream dies
 				}
+				// !activeStream && !r.isStreamingRequest && !r.isStreamingResponse
+				// just read & discard until the stream dies
 			}
 		}
 	}
@@ -264,7 +267,10 @@
 	log.Debug("Closing southbound streams")
 	r.sendClosed = true
 	for _, stream := range r.streams {
-		stream.CloseSend()
+		err := stream.CloseSend()
+		if err != nil {
+			log.Errorf("%v", err)
+		}
 	}
 	r.mutex.Unlock()