Come trasformare correttamente WS Server in RXJS Api senza soggetti nei NodeJ

Question

Qual è il modo corretto per trasformare il famoso modulo ws in una API reattiva in Node.js? Capisco che i soggetti possano aiutare a superare eventi non reattivi a eventi reattivi, ma il loro problema è che hanno un tempo molto più difficile per smaltire i loro oggetti dipendenti.

var WebSocketServer = require('ws').Server; 
 
var wss = new WebSocketServer({ port: 8080 }); 
 
var Rx = require('rx'); 
 

 

 
var connectionMessageSubject = new Rx.Subject(); 
 

 
wss.on('connection', function connection(client) { 
 
    ws.on('message', function incoming(message) { 
 
    connectionMessageSubject.onNext({ 
 
     client: client, 
 
     message: message 
 
    }); 
 
    }); 
 
});

non posso usare il loro costruito nel metodo fromEvent perché, registra tanti eventi diversi che NodeJS getta un avviso quando 30 o più client si connettono.

Per esempio ...

var WebSocketServer = require('ws').Server; 
 
var wss = new WebSocketServer({port:8080}); 
 

 
var connectionMessageObservable; 
 

 
//this uses a tremendous amount of memory and throws warnings that the event emitter has a maximum of 30 listeners 
 
wss.on('connection', function connection(client){ 
 
    connnectionMessageObservable = Rx.Observable.fromEvent(client, 'message'); 
 
});

Answer 1

Il seguente codice simula il comportamento subject.

var WebSocketServer = require('ws').Server; 
var wss = new WebSocketServer({port:8080}); 

var connectionMessage$ = new Rx.Observable(function (observer) { 
    wss.on('connection', function connection(client){ 
     client.on('message', function (message){ 
      observer.next({ 
       client: client, 
       message: message, 
      }) 
     }); 
    });  
}); 

connectionMessage$.subscribe(function (cm) { 
    // cm.client for client 
    // cm.message for message 
});