deno-zeromq
Deno bindings for ZeroMQ. (UNFINISHED! DO NOT USE IT!!!)
Examples
Request/Reply
Reply
import * as zmq from "https://deno.land/x/zeromq/mod.ts";
const socket = zmq.Reply();
await socket.bind("tcp://127.0.0.1:5555");
for await (const [req] of socket) {
console.log(`Receive: [${new TextDecoder().decode(req as Uint8Array)}]`);
socket.send("World");
}
Request
import * as zmq from "https://deno.land/x/zeromq/mod.ts";
const socket = zmq.Request();
await socket.connect("tcp://127.0.0.1:5555");
await socket.send("Hello");
const [res] = await socket.receive();
console.log(`Receive: ${new TextDecoder().decode(res as Uint8Array)}`);
TODO
- Basic ZMTP Framing
- ZMTP-NULL
- ZMTP-PLAIN
- ZMTP-CURVE
- REQ/REP
- PUB/SUB
- PUSH/PULL
- …