Real-Time Push

import { createClientConfig, PushClient } from '@tigeropenapi/tigeropen';

const config = createClientConfig();
const pc = new PushClient(config);

// Register all callbacks in one call — before connecting
pc.setCallbacks({
  onConnect: () => {
    console.log('Connected to push server');
  },
  onDisconnect: () => {
    console.log('Disconnected from push server');
  },
  onError: (err) => {
    console.error('Push error:', err.message);
  },
  onQuote: (data) => {
    // data: QuoteData (protobuf-generated)
    console.log(`Quote: ${data.symbol}  price=${data.latestPrice}  vol=${data.volume}`);
  },
  onTick: (data) => {
    // data: TradeTickData
    console.log(`Tick: ${data.symbol}`);
  },
  onOrder: (data) => {
    // data: OrderStatusData
    console.log(`Order update: id=${data.id}  status=${data.status}`);
  },
  onAsset: (data) => {
    console.log('Asset change received');
  },
  onPosition: (data) => {
    console.log('Position change received');
  },
  onTransaction: (data) => {
    console.log('Transaction received');
  },
});

await pc.connect();

pc.subscribeQuote(['AAPL', 'TSLA']);
pc.subscribeTick(['AAPL']);
pc.subscribeDepth(['AAPL']);

pc.subscribeAsset();
pc.subscribeOrder();
pc.subscribePosition();
pc.subscribeTransaction();

constructor(config: ClientConfig, options?: PushClientOptions)

connect(): Promise<void>

await pc.connect();
console.log('Ready to subscribe');

disconnect(): void

pc.disconnect();

get state(): ConnectionState

import { ConnectionState } from '@tigeropenapi/tigeropen';

if (pc.state === ConnectionState.Connected) {
  console.log('Push client is live');
}

setCallbacks(callbacks: Callbacks): void

getSubscriptions(): Map<SubjectType, string[]>
getAccountSubscriptions(): SubjectType[]

pc.setCallbacks({
  onQuote: (data) => {
    console.log(`${data.symbol}: $${data.latestPrice}`);
  },
  onDepth: (data) => {
    console.log(`Depth update for ${data.symbol}`);
    console.log('  Best bid:', data.bidList?.[0]);
    console.log('  Best ask:', data.askList?.[0]);
  },
  onKline: (data) => {
    console.log(`Kline ${data.symbol}: O=${data.open} H=${data.high} L=${data.low} C=${data.close}`);
  },
  onTransaction: (data) => {
    console.log(`Fill: ${data.symbol} qty=${data.filledQuantity} price=${data.filledPrice}`);
  },
});

subscribeQuote(symbols: string[]): void
unsubscribeQuote(symbols?: string[]): void

pc.subscribeQuote(['AAPL', 'TSLA', 'MSFT']);
pc.unsubscribeQuote(['TSLA']);

subscribeTick(symbols: string[]): void
unsubscribeTick(symbols?: string[]): void

pc.subscribeTick(['AAPL']);
pc.unsubscribeTick(['AAPL']);

subscribeDepth(symbols: string[]): void
unsubscribeDepth(symbols?: string[]): void

pc.subscribeDepth(['AAPL']);
pc.unsubscribeDepth(['AAPL']);

subscribeOption(symbols: string[]): void
unsubscribeOption(symbols?: string[]): void

pc.subscribeOption(['AAPL  250117C00150000']);
pc.unsubscribeOption(['AAPL  250117C00150000']);

subscribeFuture(symbols: string[]): void
unsubscribeFuture(symbols?: string[]): void

pc.subscribeFuture(['ES2506', 'NQ2506']);
pc.unsubscribeFuture(['ES2506']);

subscribeKline(symbols: string[]): void
unsubscribeKline(symbols?: string[]): void

pc.subscribeKline(['AAPL']);
pc.unsubscribeKline(['AAPL']);

subscribeStockTop(market: string, indicators: string[]): void
unsubscribeStockTop(market: string, indicators: string[]): void

pc.setCallbacks({
  onStockTop: (data) => {
    console.log(`[StockTop] market=${data.market} items=${data.topData?.length ?? 0}`);
  },
});
pc.subscribeStockTop('US', ['LATEST_PRICE', 'HIGHER', 'LOWER']);
pc.unsubscribeStockTop('US', ['LATEST_PRICE', 'HIGHER', 'LOWER']);

subscribeOptionTop(market: string, indicators: string[]): void
unsubscribeOptionTop(market: string, indicators: string[]): void

pc.setCallbacks({
  onOptionTop: (data) => {
    console.log(`[OptionTop] market=${data.market} items=${data.topData?.length ?? 0}`);
  },
});
pc.subscribeOptionTop('US', ['VOLUME', 'AMOUNT']);
pc.unsubscribeOptionTop('US', ['VOLUME', 'AMOUNT']);

subscribeCc(symbols: string[]): void
unsubscribeCc(symbols?: string[]): void

pc.setCallbacks({
  onQuote: (data) => {
    // Cc pushes flow through onQuote too
    console.log(`[Quote/Cc] ${data.symbol} latest=${data.latestPrice}`);
  },
});
pc.subscribeCc(['BTCUSD', 'ETHUSD']);
pc.unsubscribeCc(['BTCUSD', 'ETHUSD']);

subscribeMarket(market: string): void
unsubscribeMarket(market: string): void

pc.setCallbacks({
  onQuote: (data) => {
    // Market-status changes also arrive here
    console.log(`[Market/Quote] symbol=${data.symbol}`);
  },
});
pc.subscribeMarket('US');
pc.unsubscribeMarket('US');

subscribeAsset(account?: string): void
unsubscribeAsset(): void

pc.subscribeAsset();           // use config account
pc.subscribeAsset('DU123456'); // explicit account
pc.unsubscribeAsset();

subscribePosition(account?: string): void
unsubscribePosition(): void

pc.subscribePosition();
pc.unsubscribePosition();

subscribeOrder(account?: string): void
unsubscribeOrder(): void

pc.subscribeOrder();
pc.unsubscribeOrder();

subscribeTransaction(account?: string): void
unsubscribeTransaction(): void

pc.subscribeTransaction();
pc.unsubscribeTransaction();

// Market data subscriptions
pc.subscribeQuote(['AAPL', 'TSLA']);
pc.subscribeTick(['AAPL']);
pc.subscribeDepth(['AAPL']);
pc.subscribeOption(['AAPL  250117C00150000']);
pc.subscribeFuture(['ES2506']);
pc.subscribeKline(['AAPL']);

// Account subscriptions
pc.subscribeAsset();
pc.subscribePosition();
pc.subscribeOrder();
pc.subscribeTransaction();

// Unsubscribe from market data
pc.unsubscribeQuote(['TSLA']);
pc.unsubscribeTick(['AAPL']);
pc.unsubscribeDepth(['AAPL']);
pc.unsubscribeOption(['AAPL  250117C00150000']);
pc.unsubscribeFuture(['ES2506']);
pc.unsubscribeKline(['AAPL']);

// Unsubscribe from account events
pc.unsubscribeAsset();
pc.unsubscribePosition();
pc.unsubscribeOrder();
pc.unsubscribeTransaction();