Get started

Real-time WebSocket streams for market data, trades, positions, and more.

Mobula provides real-time WebSocket streams for accessing live blockchain data with minimal latency. Whether you need market updates, trade feeds, or position tracking, our streaming API delivers data as it happens.

TypeScript SDK (Recommended)

The easiest way to consume WebSocket streams is through our official SDK, which handles connection management, reconnection, and provides full type safety:

npm install @mobula_labs/sdk

import { MobulaClient } from '@mobula_labs/sdk';

const client = new MobulaClient({
  apiKey: 'your-api-key', // Get one at https://admin.mobula.io
});

// Subscribe to market data
client.streams.subscribe('market', { asset: 'bitcoin' }, (data) => {
  console.log('Market update:', data);
});

// Subscribe to trades
client.streams.subscribe('trade', {
  asset: 'bitcoin',
  blockchain: 'ethereum',
  pair: 'WETH/USDC',
}, (data) => {
  console.log('Trade:', data);
});

// Subscribe to OHLCV candles
client.streams.subscribe('ohlcv', {
  asset: 'bitcoin',
  interval: '1h',
}, (data) => {
  console.log('OHLCV update:', data);
});

// Subscribe to Pulse V2
client.streams.subscribe('pulse-v2', {
  model: 'default',
  chainId: ['solana:solana'],
}, (data) => {
  console.log('Pulse update:', data);
});

Available Stream Types

Stream Type	Description
market	Market data updates
market-details	Detailed market information
token-details	Token information updates
trade / fast-trade	Trade updates
ohlcv	OHLCV candle updates
holders	Token holder updates
pulse-v2	Pulse V2 data stream
position	Position updates
funding	Funding rate updates
stream-evm	EVM blockchain stream
stream-svm	Solana blockchain stream

SDK Features

• Automatic reconnection: Connection drops are handled automatically
• Heartbeat management: Keep connections alive without manual intervention
• Connection pooling: Efficient management of multiple subscriptions
• Full type safety: TypeScript types for all stream payloads
• Easy unsubscription: Clean up resources with returned unsubscribe functions

// Unsubscribe when done
const unsubscribe = client.streams.subscribe('market', { asset: 'bitcoin' }, callback);

// Later...
unsubscribe();

NPM Package

View on NPM

Need Help or Examples?

Contact Mobula support for live usage examples and integration help

Direct WebSocket Connection

If you prefer to connect directly without the SDK, you can use the WebSocket endpoint:

URL: wss://api.mobula.io

Example subscription message:

{
  "type": "market-details",
  "authorization": "YOUR-API-KEY",
  "payload": {
    "pools": [
      {
        "blockchain": "evm:1",
        "address": "0x1234567890abcdef1234567890abcdef12345678"
      }
    ]
  }
}

The SDK handles authentication, message formatting, and connection management automatically. We recommend using it for production applications.

Stream Categories

Market & Token Data

Real-time market details and token information

Trades & OHLCV

Live trade feeds and OHLCV candles

Pulse Streams

Token pulse data with customizable filters

Positions & Holders

Track positions and holder changes in real-time

Benchmarks

Live Benchmarks

Real-time latency comparisons — see how Mobula streams compare to other crypto data providers.