Jassif Team Institution

// முறை 1: require பயன்படுத்துதல்
const EventEmitter = require('events');

// முறை 2: ES6 destructuring
const { EventEmitter } = require('events');

const EventEmitter = require('events');

// புதிய EventEmitter நிகழ்வை உருவாக்கவும்
const myEmitter = new EventEmitter();

// EventEmitter ஐ விரிவுபடுத்தும் வகுப்பை உருவாக்கவும்
class MyEmitter extends EventEmitter {
  constructor() {
    super();
  }
}

// விரிவுபடுத்தப்பட்ட வகுப்பை உருவாக்கவும்
const myExtendedEmitter = new MyEmitter();

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// நிகழ்வு கேட்போரைப் பதிவு செய்யவும்
myEmitter.on('event', () => {
  console.log('ஒரு நிகழ்வு நடந்தது!');
});

// நிகழ்வை வெளியிடவும்
myEmitter.emit('event');

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// பல வாதங்களுடன் நிகழ்வு
myEmitter.on('status', (code, message) => {
  console.log(`நிலை கிடைத்தது: ${code} ${message}`);
});

// வாதங்களுடன் வெளியிடவும்
myEmitter.emit('status', 200, 'OK');

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// ஒரு முறை கேட்போரைச் சேர்க்கவும்
myEmitter.once('onetime', () => {
  console.log('இது ஒரு முறை மட்டுமே அழைக்கப்படும்');
});

// முதல் வெளியீடு - கேட்போரைத் தூண்டும்
myEmitter.emit('onetime');

// இரண்டாவது வெளியீடு - கேட்போரைத் தூண்டாது
myEmitter.emit('onetime');

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// பிழை நிகழ்வு கையாளுதல்
myEmitter.on('error', (err) => {
  console.error('பிழை ஏற்பட்டது:', err.message);
});

// பிழை நிகழ்வை வெளியிடவும்
myEmitter.emit('error', new Error('ஏதோ தவறு நடந்தது'));

// 'error' கேட்போர் சேர்க்கப்படவில்லை என்றால், Node வீசி கிராஷ் ஆகும்
// எப்போதும் பிழை கையாளுதலைச் சேர்க்கவும்!

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// சில கேட்போர்களைச் சேர்க்கவும்
myEmitter.on('event1', () => console.log('நிகழ்வு 1'));
myEmitter.on('event2', () => console.log('நிகழ்வு 2'));
myEmitter.on('event2', () => console.log('நிகழ்வு 2 மீண்டும்'));

// அனைத்து நிகழ்வு பெயர்களையும் பெறவும்
console.log('நிகழ்வு பெயர்கள்:', myEmitter.eventNames());

// குறிப்பிட்ட நிகழ்வுக்கான கேட்போர்களைப் பெறவும்
console.log('event2 க்கான கேட்போர்கள்:', myEmitter.listeners('event2'));

// கேட்போர்களை எண்ணுங்கள்
console.log('event2 க்கான கேட்போர் எண்ணிக்கை:', myEmitter.listenerCount('event2'));

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// கேட்போர் செயல்பாட்டை வரையறுக்கவும் (நீக்கத்திற்குத் தேவை)
function listener1() {
  console.log('கேட்போர் 1 இயக்கப்பட்டது');
}

function listener2() {
  console.log('கேட்போர் 2 இயக்கப்பட்டது');
}

// கேட்போர்களைச் சேர்க்கவும்
myEmitter.on('event', listener1);
myEmitter.on('event', listener2);

console.log('நீக்குவதற்கு முன் கேட்போர்கள்:', myEmitter.listenerCount('event'));

// குறிப்பிட்ட கேட்போரை நீக்கவும்
myEmitter.removeListener('event', listener1);
// அல்லது மாற்றுப் பெயரைப் பயன்படுத்துதல்: myEmitter.off('event', listener1);

console.log('நீக்கிய பின் கேட்போர்கள்:', myEmitter.listenerCount('event'));

// ஒரு நிகழ்வுக்கான அனைத்து கேட்போர்களையும் நீக்கவும்
myEmitter.removeAllListeners('event');

console.log('அனைத்தையும் நீக்கிய பின் கேட்போர்கள்:', myEmitter.listenerCount('event'));

const EventEmitter = require('events');

// அனைத்து EventEmitter நிகழ்வுகளுக்கும் இருப்பு அதிகபட்ச கேட்போர்களை அமைக்கவும்
EventEmitter.defaultMaxListeners = 15;

const myEmitter = new EventEmitter();

// குறிப்பிட்ட நிகழ்வுக்கான அதிகபட்ச கேட்போர்களை அமைக்கவும்
myEmitter.setMaxListeners(20);

console.log('இருப்பு அதிகபட்ச கேட்போர்கள்:', EventEmitter.defaultMaxListeners);
console.log('myEmitter அதிகபட்ச கேட்போர்கள்:', myEmitter.getMaxListeners());

// maxListeners ஐ விட அதிகமாகச் சேர்ப்பது எச்சரிக்கையைத் தூண்டும்
// எச்சரிக்கை சாத்தியமான நினைவக கசிவுகளை அடையாளம் காண உதவுகிறது

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// இருப்பு நடத்தை: கேட்போர்கள் சேர்க்கப்பட்ட வரிசையில் இயக்கப்படும்
myEmitter.on('event', () => console.log('முதல் கேட்போர்'));
myEmitter.on('event', () => console.log('இரண்டாவது கேட்போர்'));

// முன்னோட்ட கேட்போரைச் சேர்க்கவும் (அது முதலில் இயக்கப்படும்)
myEmitter.prependListener('event', () => console.log('முன்னோட்ட கேட்போர்'));

// ஒரு முறை முன்னோட்ட கேட்போர்
myEmitter.prependOnceListener('event', () => console.log('முன்னோட்ட ஒரு முறை கேட்போர்'));

// நிகழ்வை வெளியிடவும்
myEmitter.emit('event');

// வெளியீடு இருக்கும்:
// முன்னோட்ட ஒரு முறை கேட்போர்
// முன்னோட்ட கேட்போர்
// முதல் கேட்போர்
// இரண்டாவது கேட்போர்

const EventEmitter = require('events');

// EventEmitter ஐ விரிவுபடுத்தும் தனிப்பட்ட வகுப்பு
class MyApp extends EventEmitter {
  constructor() {
    super();
    this.name = 'MyApp';
  }

  process(data) {
    // சில செயலாக்கங்களைச் செய்யுங்கள்
    console.log(`தரவைச் செயலாக்குகிறது: ${data}`);
    
    // செயலாக்க முடிவுகளின் அடிப்படையில் நிகழ்வுகளை வெளியிடவும்
    if (data.length > 10) {
      this.emit('large-data', data);
    } else {
      this.emit('small-data', data);
    }
    
    // முடிவு நிகழ்வை வெளியிடவும்
    this.emit('processed', data);
  }
}

// ஒரு நிகழ்வை உருவாக்கவும்
const app = new MyApp();

// நிகழ்வு கேட்போர்களைப் பதிவு செய்யவும்
app.on('large-data', (data) => {
  console.log(`பெரிய தரவு கண்டறியப்பட்டது: ${data.length} பைட்டுகள்`);
});

app.on('small-data', (data) => {
  console.log(`சிறிய தரவு கண்டறியப்பட்டது: ${data.length} பைட்டுகள்`);
});

app.on('processed', (data) => {
  console.log('செயலாக்கம் முடிந்தது');
});

// பயன்பாட்டைப் பயன்படுத்தவும்
app.process('Hello');
app.process('Hello, this is a longer string of data');

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// கேட்போரைப் பதிவு செய்யவும்
myEmitter.on('event', () => {
  console.log('கேட்போர் இயக்கப்பட்டது');
});

// நிகழ்வை வெளியிடவும்
console.log('வெளியீட்டிற்கு முன்');
myEmitter.emit('event');
console.log('வெளியீட்டிற்குப் பிறகு');

// வெளியீடு:
// வெளியீட்டிற்கு முன்
// கேட்போர் இயக்கப்பட்டது
// வெளியீட்டிற்குப் பிறகு

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// setImmediate பயன்படுத்தி அசிங்க்ரோனஸ் கேட்போரைப் பதிவு செய்யவும்
myEmitter.on('async-event', () => {
  setImmediate(() => {
    console.log('அசிங்க்ரோனஸ் கேட்போர் இயக்கப்பட்டது');
  });
});

console.log('வெளியீட்டிற்கு முன்');
myEmitter.emit('async-event');
console.log('வெளியீட்டிற்குப் பிறகு');

// வெளியீடு:
// வெளியீட்டிற்கு முன்
// வெளியீட்டிற்குப் பிறகு
// அசிங்க்ரோனஸ் கேட்போர் இயக்கப்பட்டது

const EventEmitter = require('events');

// நிராகரிப்புகளைப் பிடிக்க இயலுமைப்படுத்தவும் (Node.js 12.16.0+)
const myEmitter = new EventEmitter({ captureRejections: true });

// அல்லது உலகளவில் அமைக்கவும்
// EventEmitter.captureRejections = true;

// வாக்குறுதியை வழங்கும் நிகழ்வு கையாளுதல்
myEmitter.on('async-operation', async () => {
  // இந்த நிராகரிக்கப்பட்ட வாக்குறுதி பிடிக்கப்பட்டு 'error' நிகழ்வாக மாற்றப்படும்
  throw new Error('அசிங்க்ரோனஸ் செயல்பாடு தோல்வியடைந்தது');
});

// பிழை கையாளுதல்
myEmitter.on('error', (err) => {
  console.error('பிடிக்கப்பட்ட பிழை:', err.message);
});

// நிகழ்வைத் தூண்டவும்
myEmitter.emit('async-operation');

const http = require('http');

// HTTP சேவையகம் ஒரு EventEmitter ஆகும்
const server = http.createServer();

// 'request' நிகழ்வுகளைக் கேளுங்கள்
server.on('request', (request, response) => {
  console.log(`பெறப்பட்டது ${request.method} கோரிக்கை ${request.url}க்கு`);
  response.writeHead(200, { 'Content-Type': 'text/plain' });
  response.end('Hello World\n');
});

// 'connection' நிகழ்வுகளைக் கேளுங்கள்
server.on('connection', (socket) => {
  console.log('புதிய வாடிக்கையாளர் இணைப்பு', socket.remoteAddress);
});

// 'close' நிகழ்வைக் கேளுங்கள்
server.on('close', () => {
  console.log('சேவையகம் மூடப்பட்டது');
});

// போர்ட் 8080 இல் கேளுங்கள்
server.listen(8080, () => {
  console.log('சேவையகம் போர்ட் 8080 இல் கேட்கிறது');
});

// பின்னர், சேவையகத்தை மூடலாம்
// server.close();

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

// எப்போதும் பிழை கையாளுதலைச் சேர்க்கவும்
myEmitter.on('error', (err) => {
  console.error('பிழை ஏற்பட்டது:', err);
  // பிழையை பொருத்தமாக கையாளவும்
});

const EventEmitter = require('events');
const myEmitter = new EventEmitter();

function setupHandler() {
  const handler = () => console.log('நிகழ்வு கையாளப்பட்டது');
  
  // கையாளுதலைச் சேர்க்கவும்
  myEmitter.on('some-event', handler);
  
  // ஒரு சுத்தம் செயல்பாட்டை வழங்கவும்
  return function cleanup() {
    myEmitter.removeListener('some-event', handler);
  };
}

// ஒரு கையாளுதலை அமைக்கவும்
const cleanup = setupHandler();

// பின்னர், தேவையில்லாதபோது
cleanup();

// மோசமானது - இந்த கேட்போரை பின்னர் நீக்க முடியாது
emitter.on('event', () => console.log('அநாமதேய செயல்பாடு'));

// நல்லது - குறிப்பு மூலம் நீக்கப்படலாம்
function namedHandler() {
  console.log('பெயரிடப்பட்ட செயல்பாடு');
}

emitter.on('event', namedHandler);

// பின்னர்
emitter.removeListener('event', namedHandler);