BUS/RT Python client module (async)

PyPi module: https://pypi.org/project/busrt_async

Contents

• BUS/RT Python client module (async)

  • Installation

  • Client

  • RPC client

Installation

pip3 install busrt_async

Client

class busrt_async.client.Client(path, name)

async connect()

async disconnect()

async handle_daemon_exception(e)

is_connected()

async readexactly(reader, data_len)

async send(target=None, frame=None)

subscribe(topics)

unsubscribe(topics)

class busrt_async.client.ClientFrame(qos)

is_completed()

async wait_completed(timeout=None)

class busrt_async.client.Frame(payload=None, tp=18, qos=0)

async busrt_async.client.on_frame_default(frame)

RPC client

class busrt_async.rpc.Event(tp, frame, payload_pos)

get_payload()

class busrt_async.rpc.Notification(payload=b'')

class busrt_async.rpc.Reply(result=b'')

class busrt_async.rpc.Request(method, params=b'')

class busrt_async.rpc.Rpc(client)

async call(target, request)

call0(target, request)

is_connected()

notify(target, notification)

class busrt_async.rpc.RpcCallEvent

get_payload()

is_completed()

is_empty()

async wait_completed(timeout=None)

exception busrt_async.rpc.RpcException(msg='', code=-32603)

busrt_async.rpc.format_rpc_e_msg(e)

async busrt_async.rpc.on_call_default(event)

async busrt_async.rpc.on_notification_default(event)