Lightweigt embedded topiqs (based on kafka ideas)
Project description
The sample:
from topiq import Message, Subscriber, Topic
class Worker:
def __init__(self, message: Message):
self.message = message
async def run(self):
id = self.message.as_int()
...
# Test subscriber
async def test_subscriber(self):
subscriber = Subscriber(Topic('name'), Worker)
await subscriber.send_int_message(1)
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
topiq-0.1.1b1.tar.gz
(11.6 kB
view hashes)
Built Distribution
topiq-0.1.1b1-py3-none-any.whl
(14.9 kB
view hashes)