本文档描述了 ChainStream JavaScript SDK 提供的 WebSocket 订阅方法。每个方法都是对应 WebSocket API 的封装,详细的参数说明和返回值结构请点击对应的 API 链接查看。

K线

Token

Ranking

Wallet

Trade

DexPool

连接管理

建立连接

client.stream.connect()
所有订阅方法都会返回一个 Unsubscrible 对象,可以用于取消订阅:
const subscription = client.stream.subscribeTokenCandles(/* ... */);
// 取消订阅
subscription.unsubscribe();

批量订阅

批量订阅多个数据流

使用示例

const unsubscribles = client.stream.batchSubscribe(() => [
  client.stream.subscribeWalletBalance({
    chain: 'sol',
    walletAddress: "wallet address 1",
    callback: (data: WalletBalance[]) => {
        // todo
    }
  }),
  
  client.stream.subscribeWalletBalance({
    chain: 'sol',
    walletAddress: "wallet address 2",
    callback: (data: WalletBalance[]) => {
        // todo
    }
  })
]);
详细的参数说明、数据格式和错误处理请参考 WebSocket API 文档