PubSub

Publish-subscribe messaging

Agents can use publish-subscribe messaging to communicate with each other and external systems.

Quick Start

1. Simple Usage

   import { createPubSub } from 'praisonai';
   
   const pubsub = createPubSub();
   
   // Subscribe to topic
   pubsub.subscribe('orders', (event) => {
     console.log('New order:', event.data);
   });
   
   // Publish message
   pubsub.publish('orders', { id: '123', total: 99.99 });

2. With Configuration

   const agent1 = new Agent({
     pubsub,
     onComplete: (result) => {
       pubsub.publish('task.done', result);
     }
   });
   
   pubsub.subscribe('task.done', (event) => {
     agent2.chat(`Process: ${event.data}`);
   });

User Interaction Flow

Configuration Levels

// Level 1: Function - Simple create
const pubsub = createPubSub();

// Level 2: Dict - With options
const pubsub = createPubSub({
  maxListeners: 100,
  wildcard: true
});

// Level 3: Instance - Full control
import { EventEmitterPubSub } from 'praisonai';

const pubsub = new EventEmitterPubSub({
  maxListeners: 100,
  wildcard: true,
  delimiter: '.',
  onError: (err) => console.error(err)
});

Use Cases

API Reference

Best Practices

Related