Skip to content

Commit cfa2f73

Browse files
committed
docs(kitex): add genericclient imports to all streaming code examples
1 parent e1de013 commit cfa2f73

File tree

2 files changed

+65
-0
lines changed

2 files changed

+65
-0
lines changed

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

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,14 @@ cli, err := genericclient.NewStreamingClient("destService", g,
139139
Example:
140140

141141
```go
142+
import (
143+
"context"
144+
"fmt"
145+
"time"
146+
147+
"github.com/cloudwego/kitex/client/genericclient"
148+
)
149+
142150
// initialize client streaming client using the streaming client you created
143151
streamCli, err := genericclient.NewClientStreaming(ctx, cli, "StreamRequestEcho")
144152
for i := 0; i < 3; i++ {
@@ -159,6 +167,15 @@ Note: An `io.EOF` error returned by `Recv` indicates that the server has finishe
159167
Example:
160168

161169
```go
170+
import (
171+
"context"
172+
"fmt"
173+
"io"
174+
175+
"github.com/cloudwego/kitex/client/genericclient"
176+
"github.com/cloudwego/kitex/pkg/klog"
177+
)
178+
162179
// initialize server streaming client using the streaming client you created, and send a message
163180
streamCli, err := genericclient.NewServerStreaming(ctx, cli, "StreamResponseEcho", `{"message": "grpc server streaming generic request"}`)
164181
for {
@@ -181,6 +198,16 @@ for {
181198
Example:
182199

183200
```go
201+
import (
202+
"context"
203+
"fmt"
204+
"io"
205+
"sync"
206+
207+
"github.com/cloudwego/kitex/client/genericclient"
208+
"github.com/cloudwego/kitex/pkg/klog"
209+
)
210+
184211
// initialize bidirectional streaming client using the streaming client you created
185212
streamCli, err := genericclient.NewBidirectionalStreaming(ctx, cli, "BidirectionalEcho")
186213

@@ -239,6 +266,12 @@ The usage of unary call is similar to normal (non-streaming) generic call.
239266
Example:
240267

241268
```go
269+
import (
270+
"context"
271+
272+
"github.com/cloudwego/kitex/client/genericclient"
273+
)
274+
242275
resp, err := cli.GenericCall(ctx, "UnaryEcho", `{"message": "unary request"}`)
243276
strResp, ok := resp.(string) // response is json string
244277
```

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

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,14 @@ cli, err := genericclient.NewStreamingClient(
140140
示例:
141141

142142
```go
143+
import (
144+
"context"
145+
"fmt"
146+
"time"
147+
148+
"github.com/cloudwego/kitex/client/genericclient"
149+
)
150+
143151
// 使用已创建的流式客户端初始化 client streaming
144152
streamCli, err := genericclient.NewClientStreaming(ctx, cli, "EchoClient")
145153

@@ -164,6 +172,14 @@ strResp, ok := resp.(string) // 响应为 json 字符串
164172
示例:
165173

166174
```go
175+
import (
176+
"context"
177+
"fmt"
178+
"io"
179+
180+
"github.com/cloudwego/kitex/client/genericclient"
181+
)
182+
167183
// 使用已创建的流式客户端初始化 server streaming,并发送消息
168184
streamCli, err := genericclient.NewServerStreaming(ctx, cli, "EchoServer", `{"message": "grpc server streaming generic request"}`)
169185

@@ -186,6 +202,16 @@ for {
186202
示例:
187203

188204
```go
205+
import (
206+
"context"
207+
"fmt"
208+
"io"
209+
"sync"
210+
211+
"github.com/cloudwego/kitex/client/genericclient"
212+
"github.com/cloudwego/kitex/pkg/klog"
213+
)
214+
189215
// 使用已创建的流式客户端初始化 bidirectional streaming
190216
streamCli, err := genericclient.NewBidirectionalStreaming(ctx, cli, "Echo")
191217
if err != nil {
@@ -254,6 +280,12 @@ wg.Wait()
254280
示例:
255281

256282
```go
283+
import (
284+
"context"
285+
286+
"github.com/cloudwego/kitex/client/genericclient"
287+
)
288+
257289
resp, err := cli.GenericCall(ctx, "EchoPingPong", `{"message": "unary request"}`)
258290
strResp, ok := resp.(string) // 响应为 json 字符串
259291
```

0 commit comments

Comments
 (0)