Publish/Subscribe¶

The publisher¶

sync

import rembus as rb

cli = rb.node("mynode")
cli.publish("mytopic", "mydata")

async

import rembus as rb

async main():
   cli = await rb.component("mynode")
   await cli.publish("mytopic", "mydata")

The subscriber¶

sync

import rembus as rb

def mytopic(data):
    print("Received data:", data)

sub = rb.node("mynode")
sub.subscribe(mytopic)
sub.reactive()
sub.wait()

async

import rembus as rb

def mytopic(data):
    print("Received data:", data)

async main():
    sub = await rb.component("mynode")
    await sub.subscribe(mytopic)
    await sub.reactive()
    await sub.wait()