Consolidated Trade Updates

// To subscribe
const sub = client.newSubscription("recent_trades_consolidated:global", { positioned: true, recoverable: true });

sub.on("publication", (ctx) => {
  const data = ctx.data;
  // message handler logic
});

sub.subscribe();

import asyncio
from centrifuge import Client, PublicationContext, SubscriptionEventHandler

async def on_publication(ctx: PublicationContext) -> None:
    print(ctx.data)

async def main():
    client = Client(
        "wss://realtime.sx.bet/connection/websocket",
        token="YOUR_TOKEN",  # from /user/realtime-token/api-key
    )
    await client.connect()
    handler = SubscriptionEventHandler(on_publication=on_publication)
    sub = client.new_subscription("recent_trades_consolidated:global", handler)
    await sub.subscribe()
    await asyncio.Future()  # keep running

asyncio.run(main())