@akiroz/pubsub-rpc

PubSub RPC

A generic RPC mechanism for Pub/Sub transports based on MsgPack

Supports NodeJS and modern browsers.

Why not JSON-RPC?

Native binary support for passing large binary payloads.

Mechanism

1. Callee subscribe to topic
2. Caller subscribe to topic/${base64(id)}
3. Caller publish to topic with a binary id (default 16 byte) in the payload
4. Callee calls RPC handler with params in the payload to get result or error response
5. Callee publish response to topic/${base64(id)}
6. Caller unsubscribe from topic/${base64(id)}

API

await register(pubSubClient, topic, async (params, topic) => {
    return result;
});

const result = await call(pubSubClient, topic, params);