RPC

Invoke

sync

import rembus as rb

cli = rb.node("mynode")
cli.rpc("myservice", 2, 3)

async

import rembus as rb

async main():
   cli = await rb.component("mynode")
   await cli.rpc("myservice", 2, 3)

Expose

sync

import rembus as rb

def myservice(x, y):
    return x + y

srv = rb.node("mynode")
srv.expose(myservice)
srv.wait()

async

import rembus as rb

def myservice(x, y):
    return x + y

async main():
    srv = await rb.component("mynode")
    await srv.expose(mytopic)
    await srv.wait()