Sample trio WAMP applications

callee.py

import logging

import trio
from wampproto.impl.client.trio import TrioWAMPClient


def procedure_handler(name):
    return 'Hello, {}!'.format(name)


async def main():
    async with client.connect():
        await client.register(procedure_handler, 'hello')
        await trio.sleep_forever()

logging.basicConfig(level=logging.DEBUG)
client = TrioWAMPClient('ws://localhost:8080/', 'realm1')
try:
    trio.run(main)
except KeyboardInterrupt:
    pass

caller.py

import logging

import trio
from wampproto.impl.client.trio import TrioWAMPClient


async def main():
    async with client.connect():
        print(await client.call('hello', 'World'))

logging.basicConfig(level=logging.DEBUG)
client = TrioWAMPClient('ws://localhost:8080/', 'realm1')
trio.run(main)