asynchronous - 使用 ZeroRPC 流式传输

Question

您可能知道，ZeroRPC 文档很少。我无法在 Python 服务器和 Node 客户端之间进行 Streaming 工作。

这是Python方法:

@zerorpc.stream
def PublishWhaterver(self, some_args):
    yield "love"
    yield "stack"
    yield "overflow"

这是节点调用:

export const tryStream = () => {
      connectedZerorpcClient.invoke('PublishWhatever', (error, res, more) => {
      console.log('STREAM', res, more);
  });
};

这段代码会记录“STREAM love”，然后什么都不做。

所以这里是我的问题:

在 Python 服务器代码中，我应该调用 PublishWhatever与相关的参数，以便它产生附加值？

在 Node 客户端中，当有更多数据时，我应该调用一些递归函数吗？

我试图实现的是 Pub/Sub 系统，但现在实现似乎只存在于 Python 服务器和 Python 客户端，没有 Node 示例。

主页上的示例和测试也不相关，它显示了当 invoke 时如何流式传输已存在的数组。方法被调用。这里的消息是在一些繁重的计算过程中生成的，我希望服务器能够告诉客户端“这里，一些数据准备好了”并且永远不会断开连接。

Answer 1

那么， ZeroRPC 积极宣传，它使用自己的 python 实现代码作为事情如何工作的自我文档。换句话说，没有人花费额外的努力来发布以用户为中心的文档，更不用说以学习过程为中心的文档了。

无论如何，尽量遵守 ZeroRPC 描述中的少数“可见”语句。

@zerorpc.stream
def PublishWhaterver(self, some_args):
    yield ( "love", "stack", "overflow", ) # one, tuple-wrapped result-container