42 lines
622 B
Go
42 lines
622 B
Go
package logic
|
|
|
|
import (
|
|
"context"
|
|
"linkpay/internal/service"
|
|
"log"
|
|
|
|
"git.linkiio.cn/linkpay/protobuf"
|
|
)
|
|
|
|
/*
|
|
*
|
|
- 双向通信流示例查询订单
|
|
- @param void
|
|
- @author dc.To
|
|
- @version 20250429
|
|
- ApiOrders(ctx, &protobuf.Orders{
|
|
Org: "org",
|
|
})
|
|
*/
|
|
func ApiOrders(ctx context.Context, req *protobuf.Orders) {
|
|
|
|
client := service.BssClient()
|
|
|
|
stream, _ := client.Order(context.Background())
|
|
|
|
//查询协程
|
|
go func() {
|
|
stream.Send(req)
|
|
stream.CloseSend()
|
|
}()
|
|
|
|
//监听返回
|
|
for {
|
|
res, err := stream.Recv()
|
|
if err != nil {
|
|
break
|
|
}
|
|
log.Printf("Got order response: %v", res)
|
|
}
|
|
}
|