Subscribing to Events

const connection = await Threadify.connect('your-api-key', 'my-service', {
  maxInFlight: 50  // Default: 10, Max: 100
});

// Thread events (2 parameters)
connection.on('thread.completed', (notification) => {
  console.log('Thread completed');
  notification.ack();
});

// Step events (3 parameters: event, stepName, handler)
connection.on('step.failed', 'payment_processed', (notification) => {
  console.error('Payment failed:', notification.message);
  notification.ack();
});

// Contract-specific (use @ syntax)
connection.on('rule.violated', 'product_delivery@order_placed', (notification) => {
  console.error('Contract violation:', notification.message);
  notification.ack();
});