Realtime Streams

Comparable to: Socket.io, Pusher, Firebase Realtime

Key Concepts

Use the concepts below when they fit the task. Not every stream setup needs all of them.

• iii-stream serves WebSocket connections on the configured stream port (default 3112)
• Clients connect at ws://host:{stream_port}/stream/{stream_name}/{group_id}
• stream::set / stream::get / stream::list / stream::delete provide CRUD for stream items
• stream::send pushes events to all connected clients in a stream group
• createStream registers a custom adapter for non-default stream backends
• Each stream item is identified by stream_name, group_id, and item_id; data is the item payload

Architecture

Function
  → trigger('stream::set', { stream_name, group_id, item_id, data })