whereismysock 2019.6.0

一种在Python迭代器协议之上构建的、处理从WebSocket信息流便捷方式。

当订阅一个合格数据流时，我通常对最新的值感兴趣，即当我准备使用它时的值，或者自从上次检查以来所有的值。

whereismysock还有一个cite>最多订阅者，它具有一个上限，即它保留在内存中的消息数量（首先删除最旧的）。

>>> from whereismysock import latest
>>> usdjpy = latest("ws://toplevel/USDJPY")
>>> next(usdjpy)
...

>>> from whereismysock import all
>>> nk225 = all("ws://trades/NK225")
>>> next(nk225)
...

我喜欢它，因为它使得“同步”不同来源的信息变得超级简单。

>>> hhi = latest("ws://toplevel/HHI")
>>> hsi = latest("ws://toplevel/HSI")
>>> next(zip(hhi, hsi))
...