Streaming

El SDK de TypeScript ofrece funciones de streaming en tiempo real para flujos de datos en vivo.

​

Streaming básico

Conéctate a publicaciones muestreadas en tiempo real:

stream.ts

import { Client } from '@xdevplatform/xdk';

const client: Client = new Client({ bearerToken: 'your-bearer-token' });

// 1 % de publicaciones públicas muestreadas
const stream = await client.stream.postsSample({
  tweetfields: ['id','text','created_at'],
  expansions: ['author_id'],
  userfields: ['id','username','name']
});

// Escucha los eventos
stream.on('data', (event) => {
  // event es la línea JSON parseada (data/includes/matching_rules)
  console.log('Datos nuevos:', event);
});

stream.on('error', (e) => console.error('Error del stream:', e));
stream.on('close', () => console.log('Stream cerrado'));

​

Iteración asíncrona

Consume el stream con iteración asíncrona:

async.ts

const stream = await client.stream.postsSample();
for await (const event of stream) {
  // Cada evento es una línea JSON procesada (data/includes/matching_rules)
  console.log(event);
}

​

Gestión de streams

Controla el ciclo de vida desde el stream basado en eventos:

// Cerrar el stream
stream.close();

// Reconexión automática (si está habilitada por tu wrapper)
// El EventDrivenStream predeterminado expone hooks básicos de reconexión

​

Gestión de errores

Controla los errores de streaming y las reconexiones:

stream.on('error', (event) => {
  const err = event.error || event;
  console.error('Error de transmisión:', err);
});

stream.on('keepAlive', () => {
  // evento de heartbeat
});