All Exchanges.
One Feed.
Zero GC.

import zmq

ctx  = zmq.Context()
sock = ctx.socket(zmq.DEALER)
sock.setsockopt(zmq.ROUTING_ID, b"my-client:DLEflKfiKZdZxGKa") # unique-id:token — change "my-client" to anything unique
sock.connect("tcp://free_api.arbstream.net:6001") # orderbook stream; ticker on 6002
sock.send(b"") # register with the server

while True:
    print(sock.recv_string())

// brew install zeromq czmq libsodium pkg-config
// go get gopkg.in/zeromq/goczmq.v4
package main

import (
    "fmt"
    "log"
    "github.com/zeromq/goczmq"
)

func main() {
    dealer := goczmq.NewSock(goczmq.Dealer)
    defer dealer.Destroy()
    dealer.SetIdentity("my-client:DLEflKfiKZdZxGKa") // unique-id:token — change "my-client" to anything unique

    // orderbook stream; ticker stream available on port 6002
    if err := dealer.Connect("tcp://free_api.arbstream.net:6001"); err != nil {
        log.Fatal(err)
    }
    dealer.SendFrame([]byte{}, goczmq.FlagNone) // register with the server

    for {
        msg, _, err := dealer.RecvFrame()
        if err != nil {
            log.Fatal(err)
        }
        fmt.Println(string(msg))
    }
}

// build.zig.zon: zig fetch --save git+https://github.com/uyha/zimq.git
const std = @import("std");
const zimq = @import("zimq");

pub fn main() !void {
    var ctx = try zimq.Context.init();
    defer ctx.deinit();

    // create DEALER socket
    var dealer = try zimq.Socket.init(ctx, .dealer);
    defer dealer.deinit();

    // set routing ID before connecting
    try dealer.set(.routing_id, "my-client:DLEflKfiKZdZxGKa"); // unique-id:token — change "my-client" to anything unique
    // orderbook stream; ticker stream available on port 6002
    try dealer.connect("tcp://free_api.arbstream.net:6001");
    try dealer.sendSlice("", .{}); // register with the server

    while (true) {
        var msg = zimq.Message.empty();
        defer msg.deinit();
        _ = try dealer.recvMsg(&msg, .{});

        std.log.info("{s}\n", .{msg.slice()});
    }
}