docs: fix typos and update streamx documentation (#1506)

Signed-off-by: rogerogers <rogers@rogerogers.com>

Author: rogerogers

content/en/docs/kitex/Tutorials/basic-feature/streamx/StreamX_Basic_Programming.md

@@ -31,7 +31,7 @@ The protocol selected here only affects code generated from IDL. Regardless of t
 
 File `echo.thrift `:
 
-```go
+```thrift
 namespace go echo
 
 service TestService {
@@ -65,8 +65,10 @@ import "github.com/cloudwego/kitex/client"
 
 cli, err := testservice.NewClient(
     "a.b.c",
-    client.WithStreamRecvMiddleware(...),
-    client.WithStreamSendMiddleware(...),
+    client.WithStreamOptions(
+        client.WithStreamRecvMiddleware(...),
+        client.WithStreamSendMiddleware(...),
+    ),
 )
 ```
 
@@ -78,8 +80,10 @@ import "github.com/cloudwego/kitex/server"
 
 svr := testservice.NewServer(
     new(serviceImpl),
-    server.WithStreamRecvMiddleware(...),
-    server.WithStreamSendMiddleware(...),
+    server.WithStreamOptions(
+        server.WithStreamRecvMiddleware(...),
+        server.WithStreamSendMiddleware(...),
+    ),
 )
 ```
 

content/en/docs/kitex/Tutorials/basic-feature/streamx/StreamX_Error_Handling.md

@@ -56,7 +56,7 @@ Usage example: For example, in the ChatGPT scenario, we need to constantly check
 ```go
 func (si *streamingService) ServerStreamWithErr(ctx context.Context, req *echo.Request, stream echo.TestService_ServerStreamWithErrServer) error {
     // Check user account balance
-    for isHasBalance (req.UserId) {
+    for hasBalance(req.UserId) {
         stream.Send(ctx, res)
     }
     // Return insufficient user balance error

content/en/docs/kitex/Tutorials/basic-feature/streamx/StreamX_FAQ.md

@@ -16,11 +16,11 @@ Note that since the check depends on the GC timing, the delay monitoring of the
 
 ### Client persistent stream object causes stream leak
 
-If the user holds the stream object for a long time and does not actively call stream. CloseSend, the framework will naturally assume that the stream still needs to be used, and will not close the stream and related gorotuines.
+If the user holds the stream object for a long time and does not actively call stream.CloseSend(), the framework will naturally assume that the stream still needs to be used, and will not close the stream and related goroutines.
 
 ### Server call Recv stuck
 
-If the client keeps a stream active and does not call CloseSend, the stream. Recv () function will not return.
+If the client keeps a stream active and does not call CloseSend, the stream.Recv() function will not return.
 
 If the server wants to avoid problems caused by incorrect usage of client users, it can customize its own timeout logic in the ctx of Recv (ctx). For example:
 

content/en/docs/kitex/Tutorials/basic-feature/streamx/StreamX_Metainfo.md

@@ -42,7 +42,7 @@ Reverse pass-through introduces a new concept, Header and Trailer. Any complete
 Use these two frames to reverse pass-through information.
 
 ```go
-import "github.com/cloudwego/pkg/streaming"
+import "github.com/cloudwego/kitex/pkg/streaming"
 
 func (s *streamingService) EchoClient(ctx context.Context,
     stream echo.TestService_EchoClientServer) (err error) {
@@ -55,7 +55,7 @@ func (s *streamingService) EchoClient(ctx context.Context,
         return err
     }
     // send normal data
-    err = stream.Send(req)
+    err = stream.Send(ctx, resp)
 }
 ```
 

content/en/docs/kitex/Tutorials/basic-feature/streamx/StreamX_Middleware.md

@@ -76,7 +76,7 @@ type UnaryMiddleware func(next UnaryEndpoint) UnaryEndpoint
 ### Inject client-side middlewares
 
 ```go
-import "github.com/cloudwego/client"
+import "github.com/cloudwego/kitex/client"
 
 cli, err := xxx.NewClient(
     "a.b.c",
@@ -109,7 +109,7 @@ cli, err := xxx.NewClient(
 ### Inject server-side middlewares
 
 ```go
-import "github.com/cloudwego/server"
+import "github.com/cloudwego/kitex/server"
 
 svr, err := xxx.NewServer(
     //...

content/en/docs/kitex/Tutorials/options/client_options.md

@@ -91,6 +91,17 @@ func WithMiddlewareBuilder(mwb endpoint.MiddlewareBuilder) Option
 
 Add middleware depends on the context passed in by the framework that contains runtime configuration information (the context of non-RPC calls), so that the middleware can take advantage of the framework's information when initializing.
 
+### WithStreamOptions
+
+```go
+func WithStreamOptions(opts ...client.StreamOption) Option
+```
+
+**Kitex >= v0.13.0 adds this option.**
+
+Aggregate streaming-related options such as StreamMiddleware, StreamSendMiddleware, StreamRecvMiddleware, RecvTimeout. Works for streaming methods.
+See [StreamX Middleware](../../basic-feature/streamx/streamx_middleware/).
+
 ### WithCircuitBreaker
 
 ```go

content/en/docs/kitex/Tutorials/options/server_options.md

@@ -64,6 +64,17 @@ func WithMiddlewareBuilder(mwb endpoint.MiddlewareBuilder, funcName ...string) O
 
 Add middleware depends on the context passed in by the framework that contains runtime configuration information (the context of non-RPC calls), so that the middleware can take advantage of the framework's information when initializing.
 
+### WithStreamOptions
+
+```go
+func WithStreamOptions(opts ...server.StreamOption) Option
+```
+
+**Kitex >= v0.13.0 adds this option.**
+
+Aggregate streaming-related options such as StreamMiddleware, StreamSendMiddleware, StreamRecvMiddleware, RecvTimeout. Works for streaming methods.
+See [StreamX Middleware](../../basic-feature/streamx/streamx_middleware/).
+
 ### WithLimit
 
 ```go

content/zh/docs/kitex/Tutorials/basic-feature/streamx/StreamX_Basic_Programming.md

@@ -31,7 +31,7 @@ description: ""
 
 文件 `echo.thrift`:
 
-```go
+```thrift
 namespace go echo
 
 service TestService {
@@ -60,14 +60,16 @@ kitex -streamx -module <go module> -service service echo.thrift
 #### 创建 Client
 
 ```go
-// 生成代码目录，streamserver 为 IDL 定义的 service name
+// 生成代码目录，testservice 为 IDL 定义的 service name
 import ".../kitex_gen/echo/testservice"
 import "github.com/cloudwego/kitex/client"
 
 cli, err := testservice.NewClient(
     "a.b.c",
-    client.WithStreamRecvMiddleware(...),
-    client.WithStreamSendMiddleware(...),
+    client.WithStreamOptions(
+        client.WithStreamRecvMiddleware(...),
+        client.WithStreamSendMiddleware(...),
+    ),
 )
 ```
 
@@ -79,8 +81,10 @@ import "github.com/cloudwego/kitex/server"
 
 svr := testservice.NewServer(
     new(serviceImpl),
-    streamxserver.WithStreamRecvMiddleware(...),
-    streamxserver.WithStreamSendMiddleware(...),
+    server.WithStreamOptions(
+        server.WithStreamRecvMiddleware(...),
+        server.WithStreamSendMiddleware(...),
+    ),
 )
 ```
 
@@ -111,9 +115,9 @@ client.CloseAndRecv(res) === EOF ==>       server.Recv(EOF)
 ```go
 stream, err := cli.EchoClient(ctx)
 for i := 0; i < 3; i++ {
-    err = cs.Send(stream.Context(), req)
+    err = stream.Send(stream.Context(), req)
 }
-res, err = cs.CloseAndRecv(stream.Context())
+res, err = stream.CloseAndRecv(stream.Context())
 ```
 
 #### Server 用法
@@ -220,7 +224,7 @@ go func() {
     for i := 0; i < round; i++ {
        err := stream.Send(stream.Context(), req)
     }
-    err = bs.CloseSend(stream.Context())
+    err = stream.CloseSend(stream.Context())
 }()
 go func() {
     defer wg.Done()

content/zh/docs/kitex/Tutorials/basic-feature/streamx/StreamX_Error_Handling.md

@@ -56,7 +56,7 @@ TTHeader Streaming 错误汇总
 ```go
 func (si *streamingService) ServerStreamWithErr(ctx context.Context, req *echo.Request, stream echo.TestService_ServerStreamWithErrServer) error {
     // 检查用户账户余额
-    for isHasBalance (req.UserId) {
+    for hasBalance(req.UserId) {
         stream.Send(ctx, res)
     }
     // 返回用户余额不足错误

content/zh/docs/kitex/Tutorials/basic-feature/streamx/StreamX_FAQ.md

@@ -16,7 +16,7 @@ kitex 会在检查用户不再持有 stream 对象时，主动调用一次 Close
 
 ### Client 持久化 stream 导致 stream 泄漏
 
-如果用户长期持有 stream 对象，而且不主动调用 stream.CloseSend ，框架会理所应当认为该 stream 还需要被使用，进而不会关闭 stream 以及相关 gorotuine。
+如果用户长期持有 stream 对象，而且不主动调用 stream.CloseSend()，框架会认为该 stream 仍需使用，进而不会关闭 stream 以及相关 goroutine。
 
 ### Server 调用 Recv 卡死