A convenient way to work with websocket data streams
Project description
A convenient way to work with information streaming from websockets, built on top of the Python iterator protocol.
When subscribing to a stream of qualified data I am usually interested in either
the latest
value i.e. the one I want when I am ready to do something
with it or all
the values since I last checked.
whereismysock
also has a most
subscriber which is all
with an upper bound
to the number of messages it keeps in memory (deleting the eldest first).
>>> from whereismysock import latest
>>> usdjpy = latest("ws://toplevel/USDJPY")
>>> next(usdjpy)
...
>>> from whereismysock import all
>>> nk225 = all("ws://trades/NK225")
>>> next(nk225)
...
I like it because it makes "synchronising" different source of information super easy.
>>> hhi = latest("ws://toplevel/HHI")
>>> hsi = latest("ws://toplevel/HSI")
>>> next(zip(hhi, hsi))
...
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
whereismysock-2019.3.0.tar.gz
(2.4 kB
view hashes)