@nolag/stream

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

import { NoLag } from '@nolag/js-sdk'
import { NoLagStream } from '@nolag/stream'

// The app owns one core client. In a browser, pass a token provider so the
// SDK can mint fresh short-lived client tokens from your backend.
const client = NoLag(async () => (await (await fetch('/api/nolag-token')).json()).token)

// Inject the client into the stream wrapper (role: 'viewer', 'moderator', or 'host')
const stream = new NoLagStream({ client, username: 'Alice', role: 'viewer' })

await client.connect()   // the app owns the connection
await stream.ready()     // wrapper setup complete

// 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}`))
})

// Teardown: the wrapper releases its handlers; the app closes the socket.
stream.detach()
client.disconnect()