jeruthadam

// класс для очереди
class Queue{
	constructor(interval=1000) {
		this.list = [];
		setInterval(()=>{
			const item = this.list.shift();
			if( item && item.cb && typeof item.cb === "function" ){
				item.cb(...item.params);
			}
		},interval);
	}
	addTask(cb, ...params){
		this.list.push({cb:cb, params:params});
	}
}


// экземпляр класса для очеред. устанавливаем интервал срабатывания 2 секунды
const queue = new Queue(2000);

// links - ваш мап
links.forEach(b => {
	// хз как вы используете b, в вашем коде это не показано
	queue.addTask(()=>{
		// но вы вполне можете использовать ваше b тут
		fetchDonor();	
	});
});

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

wss.on('connection', ws => {
  pubsub.on('test', (payload, _ws) => {
    if (_ws !== ws) {
      return;
    }
    ws.send(payload);
  });
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, payload, ws);
  });
})

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

wss.on('connection', ws => {
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, payload, ws);
  });
});

 pubsub.on('test', (payload, _ws) => {
   _ws.send(payload);
});

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

wss.on('connection', ws => {
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, { payload, ws });
  });
});

 pubsub.on('test', ({ payload, ws }) => {
   ws.send(payload);
});

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

wss.on('connection', ws => {
  ws.on('message', message => {
    const { event, payload } = message;
    pubsub.emit(event, payload, outcome => ws.send(outcome));
  });
});

 pubsub.on('test', (payload, send) => {
   send(payload);
});