Autobahn~Sync
Autobahn integration with crochet to provide WAMP for synchronous applications.
Originaly based on the work of Sam & Max (warning: French, pr0n and awesomeness inside !).
Quick example
from time import sleep
from autobahn_sync import publish, call, register, subscribe, run
@register('com.app.shout')
def shout(msg):
return msg.upper()
@subscribe('com.app.idea')
def on_thought(msg):
print("I've just had a new idea: %s" % msg)
run()
while True:
print(call('com.app.shout', 'Autobahn is cool !'))
publish('com.app.idea', 'Use autobahn everywhere !')
sleep(1)
This code will connect to the crossbar router (don’t forget to start it before trying this snippet !) listening ws://127.0.0.1:8080/ws and register itself in realm realm1.
Also see the examples for more usecases
Bonus
See extensions folder for a nice Flask extension ;-)
Get it now
pip install -U autobahn-sync
License
MIT licensed. See the bundled LICENSE file for more details.
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
autobahn-sync-0.3.2.tar.gz
(7.6 kB
view details)
File details
Details for the file autobahn-sync-0.3.2.tar.gz.
File metadata
- Download URL: autobahn-sync-0.3.2.tar.gz
- Upload date:
- Size: 7.6 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
1b9aebab11680005fde3c0e9d0cf5d24929f0b01336f06b866c1cea0408bf6d0
|
|
| MD5 |
c12e8ebbeca71cc4849fdead8c056e2d
|
|
| BLAKE2b-256 |
1857116421184bb019190d649591f221303f64002273e359d06ad332ea06c0a7
|