Streaming Token Prices with SSE

Receive real-time token price updates via Server-Sent Events (SSE). Stream USD prices for any token with simple HTTP streaming.

Overview

Stream real-time token USD prices via Server-Sent Events (SSE) with DexPaprika’s public streaming endpoint. Get price updates roughly every 1 second with no API key required.

Base URL: https://streaming.dexpaprika.com Endpoint: GET /stream Protocol: HTTP/1.1 with text/event-stream (SSE)

---

Getting started

Connect in seconds - no authentication required. One connection streams one asset.

Basic example

curl -N "https://streaming.dexpaprika.com/stream?method=t_p&chain=ethereum&address=0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2"

This opens a streaming connection to Ethereum WETH price updates.

---

Request parameters

Parameter	Type	Required	Description
method	string	Yes	Streaming method. Must be t_p (token price)
chain	string	Yes	Blockchain network slug (e.g., ethereum, solana)
address	string	Yes	Token contract address or canonical address on the chain
limit	integer	No	Optional: close stream after emitting N events

Request examples

Ethereum WETH (3 messages)

curl -N "https://streaming.dexpaprika.com/stream?method=t_p&chain=ethereum&address=0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2&limit=3"

---

Response format

Status: 200 OK on success Content-Type: text/event-stream Format: Newline-delimited SSE events

Event payload

data: {"a":"<token_address>","c":"<chain>","p":"<price_usd>","t":<unix_timestamp>}
event: t_p

Response fields

Field	Type	Description
a	string	Token address
c	string	Chain slug
p	string	Price in USD (numeric string for precision)
t	integer	Send timestamp (Unix seconds)

Example response

{"a":"0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2","c":"ethereum","p":"3997.5514026436525223","t":1761733397}

---

Usage examples

Node.js quick listener

JavaScript

const url = new URL('https://streaming.dexpaprika.com/stream');
url.searchParams.set('method', 't_p');
url.searchParams.set('chain', 'ethereum');
url.searchParams.set('address', '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2');
url.searchParams.set('limit', '5');

(async () => {
  const res = await fetch(url.toString());
  if (!res.ok) throw new Error(`HTTP ${res.status}`);
  const reader = res.body.getReader();
  const decoder = new TextDecoder();
  let buf = '';

  for (;;) {
    const { value, done } = await reader.read();
    if (done) break;
    buf += decoder.decode(value, { stream: true });
    const chunks = buf.split('\n\n');
    buf = chunks.pop() || '';

    for (const chunk of chunks) {
      const lines = chunk.split('\n').filter(Boolean);
      const map = Object.fromEntries(lines.map(line => {
        const i = line.indexOf(': ');
        return i > 0 ? [line.slice(0, i), line.slice(i + 2)] : [line, ''];
      }));
      if (map.event && map.data) {
        try {
          const payload = JSON.parse(map.data);
          console.log(`[${map.event}]`, payload);
        } catch (e) {
          console.warn('Bad JSON:', map.data);
        }
      }
    }
  }
})().catch(err => {
  console.error(err);
  process.exit(1);
});

Browser (EventSource)

function startStream() {
  const url = new URL('https://streaming.dexpaprika.com/stream');
  url.searchParams.set('method', 't_p');
  url.searchParams.set('chain', 'ethereum');
  url.searchParams.set('address', '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2');

  const es = new EventSource(url.toString());

  function handle(evt) {
    try {
      const data = JSON.parse(evt.data);
      console.log(`[${evt.type}]`, data);
    } catch (_) {}
  }

  es.addEventListener('t_p', handle);

  es.onerror = () => {
    // Simple reconnect on error
    es.close();
    setTimeout(startStream, 1000);
  };
}

startStream();

---

Error handling

HTTP status codes

Status	Reason	Resolution
400 Bad Request	Missing/invalid parameters	Check method, chain, address, limit
400 Unsupported chain	Chain not supported	Use /networks endpoint to find valid chains
400 Asset not found	Token address invalid for chain	Verify address belongs to the specified chain
429 Too Many Requests	Global capacity exceeded	Retry with exponential backoff

Common errors

invalid method: method must be 't_p'
asset address is required
chain is required
unsupported chain
asset not found
invalid limit parameter
limit must be greater than 0

Validation occurs in sequence. When testing limit errors, use a known-valid token address (e.g., WETH on Ethereum) to avoid hitting asset not found before the limit validation.

---

Integration tips

Supported Networks

Use the Networks endpoint to discover supported chains.

One Asset Per Connection

Open separate connections for multiple assets. This endpoint streams a single token per connection.

Handle Precision

Parse numeric strings as numbers to preserve price precision in your client.

Reconnection Logic

Implement standard SSE reconnection patterns to handle network interruptions gracefully.

---

Next steps

Quick API Reference

Explore REST endpoints for historical data and batch operations.

More Tutorials

Learn other ways to integrate DexPaprika into your applications.

Get support

Join Discord

Connect with our community and get real-time support.

Give Feedback

Share your experience and help us improve.

---

FAQs

Do I need an API key?

No. The streaming endpoint is public; no API keys or registration required.

How many assets can I stream at once?

This endpoint streams one asset per connection. For multiple assets, open separate connections.

What is the price update frequency?

Target emission is ~1 second per connection, subject to server load and network conditions.

How do I handle connection drops?

Implement standard SSE reconnection logic with exponential backoff on network failures.

Are prices in USD only?

Yes, this endpoint provides prices in USD. Numeric values are provided as strings to preserve precision.