本文介绍了Protobuf支持Tuples吗？的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我要从GRPC服务器流式传输字符串元组。
我似乎找不到一个聪明的方法(如果有的话)来做这件事。你们中有谁用过Protobuf中的元组吗？
其他信息：
我使用的是F#，我想要相应的
string * string
推荐答案
您使用的是什么库？我可以用protobuf-net.Grpc来做这件事。我的服务如下所示：
member __.SubscribeTupleAsync() =
asyncSeq {
while true do
let time = DateTime.Now
yield string time.Minute, string time.Second
do! Async.Sleep 1000
} |> AsyncSeq.toAsyncEnum
我的客户端如下所示：
use http = GrpcChannel.ForAddress("http://localhost:10042")
let client = http.CreateGrpcService<ITimeService>()
async {
for (min, sec) in client.SubscribeTupleAsync() |> AsyncSeq.ofAsyncEnum do
printfn "%s, %s" min sec
} |> Async.RunSynchronously
合同为：
[<ServiceContract>]
type ITimeService =
abstract member SubscribeTupleAsync : unit -> IAsyncEnumerable<string * string>
.proto文件为：
syntax = "proto3";
package ProtobufCommon;
import "google/protobuf/empty.proto";
message Tuple_String_String {
string Item1 = 1;
string Item2 = 2;
}
service TimeService {
rpc SubscribeTuple (.google.protobuf.Empty) returns (stream Tuple_String_String);
}
客户端的输出为：
3, 26
3, 27
3, 28
3, 29
3, 30
3, 31
3, 32
3, 33
3, 34
3, 35
...
这篇关于Protobuf支持Tuples吗？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除！