@nolag/stream

Live streaming engagement with comments, reactions, and polls.

Overview

@nolag/stream adds real-time viewer engagement to any live stream. Viewers can post comments, fire reaction bursts, and vote in polls, all delivered with sub-100ms latency. Broadcasters get live viewer counts, comment moderation hooks, and the ability to create and close polls on the fly. Comments are replayed on join so late arrivals see the full conversation; reactions and poll votes are ephemeral to keep things snappy.

Key Features

• Threaded comment stream with 7-day replay for late joiners
• Ephemeral reaction bursts for fire-and-forget emoji animations
• Live polls with real-time vote tallying and automatic close
• Live viewer count updated as viewers join and leave
• 1-day poll result replay so viewers can see recent poll outcomes
• Automatic reconnection with state restoration

How It Works

NoLagStream wraps the @nolag/js-sdk client and maintains a lobby for viewer counts. Calling joinStream() creates a StreamRoom that subscribes to three topics: comments for durable comment history, _reactions for ephemeral emoji bursts, and polls for durable poll state. A CommentStore accumulates comments while a PollManager tracks the active poll and its running vote totals.

Installation

npm install @nolag/stream @nolag/js-sdk

Quick Start

import { NoLagStream } from '@nolag/stream'

// Create and connect the client
const stream = new NoLagStream('your-access-token', {
  user: { id: 'viewer-123', name: 'Alice' },
})

await stream.connect()

// Join a stream session
const room = await stream.joinStream('live-event-2026')

// Display live viewer count
stream.on('viewerCountChanged', ({ count }) => {
  console.log('Viewers:', count)
})

// Send a comment
await room.sendComment('This is amazing!')

// Listen for comments from other viewers
room.on('comment', (c) => {
  console.log(`[${c.author.name}]: ${c.text}`)
})

// Send a reaction burst
await room.sendReaction('🔥')

room.on('reaction', ({ emoji, count }) => {
  console.log(`${count}x ${emoji}`)
})

// Create a poll (typically broadcaster-side)
const poll = await room.createPoll({
  question: 'Which feature next?',
  options: ['Dark mode', 'Mobile app', 'API access'],
  durationMs: 60_000,
})

// Vote on the active poll
await room.votePoll(poll.pollId, 1) // vote for index 1

room.on('pollUpdated', (p) => {
  console.log('Results:', p.options.map(o => `${o.label}: ${o.votes}`))
})

await stream.leaveStream('live-event-2026')
stream.disconnect()

API Reference

NoLagStream

The main class. Manages the WebSocket connection, lobby viewer counts, and stream room lifecycle.

Events: NoLagStream

StreamRoom

Returned by joinStream(). Handles comments, reactions, polls, and per-stream viewer presence.

Events: StreamRoom