yr.fnruntime.Consumer.receive#
- Consumer.receive(self, timeout_ms: int, expect_num: int = None) List[Element]#
消费者接收数据带有订阅功能，接收数据会等待期望个数 expectNum 个 elements，当超时时间 timeout_ms 到达或者期望个数的数据可接受到时，调用返回。
- 参数：
timeout_ms (int) – 超时时间。
expect_num (int，可选) – 期望接收 elements 的个数。
- 异常：
RuntimeError – 如果接收数据失败。
- 返回：
实际接收到的 elements。 数据类型：List[Element]。