Skip to content

Commit 44fd9f6

Browse files
committed
docs(kitex): align generic streaming code examples with kitex-examples demo
1 parent b8a6e42 commit 44fd9f6

File tree

1 file changed

+2
-12
lines changed

1 file changed

+2
-12
lines changed

content/zh/docs/kitex/Tutorials/advanced-feature/generic-call/generic_streaming.md

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -54,15 +54,9 @@ ctx := context.Background()
5454
// 初始化泛化客户端
5555
dOpts := proto.Options{}
5656
p, err := generic.NewPbFileProviderWithDynamicGo(idlPath, ctx, dOpts)
57-
if err != nil {
58-
log.Fatal(err)
59-
}
6057

6158
// 创建 JSON 泛化对象
6259
g, err := generic.JSONPbGeneric(p)
63-
if err != nil {
64-
log.Fatal(err)
65-
}
6660

6761
// 初始化流式客户端
6862
cli, err := genericclient.NewStreamingClient(
@@ -114,23 +108,19 @@ service TestService {
114108
```go
115109
// 1. 创建 Thrift 文件提供者
116110
p, err := generic.NewThriftFileProvider("../idl/streaming.thrift")
117-
if err != nil {
118-
log.Fatal(err)
119-
}
120111

121112
// 2. 创建 JSON Thrift 泛化调用
122113
g, err := generic.JSONThriftGeneric(p)
123-
if err != nil {
124-
log.Fatal(err)
125-
}
126114

127115
// 3. 创建流式客户端
128116
cli, err := genericclient.NewStreamingClient(
129117
"streaming_service",
130118
g,
131119
client.WithTransportProtocol(transport.GRPC),
132120
client.WithHostPorts("127.0.0.1:8888"),
121+
client.WithMetaHandler(transmeta.ClientHTTP2Handler),
133122
)
123+
134124
// ... 其他流式调用示例 ...
135125
```
136126

0 commit comments

Comments
 (0)