Sign In
Stream Processor

Stream Processor

Example project demonstrating real-time top-K stream processing.

Features

  • Top-K Processing: Maintains the top 3 highest values in real-time
  • Real-time Updates: All connected clients see changes immediately
  • Stream Statistics: Total count, highest value, and live metrics
  • Interactive Input: Add custom values or generate random numbers
  • Reset Functionality: Clear the stream and start fresh
  • Responsive Design: Clean, modern interface with live statistics

Implementation

This stream processor uses a Top-K algorithm to efficiently maintain the top 3 values using insertion sort. Updates are instantly sent to all connected clients via event broadcasting. The actor maintains persistent state tracking values and statistics, and multiple users can add values simultaneously.

  • Actor Definition (src/backend/registry.ts): Implements the streamProcessor actor with insertion-based Top-K maintenance with O(k) complexity for efficiently maintaining the highest values

Resources

Read more about state management, actions, and events.

Related Templates

AI Agent Chat

Example project demonstrating AI agent integration.

AI Agent Chat

Chat Room

Example project demonstrating real-time messaging and actor state management.

Chat Room

Real-time Collaborative Cursors

Example project demonstrating real-time cursor tracking and collaborative canvas.

Real-time Collaborative Cursors