Server sourceConnect

sourceConnect.js

var io = require('socket.io')(server);
var sourceConnect = Rx.Observable.create(function(observer) {
    
    io.on('connection', function(socket) {
        socket.emit('my socketId', {'socketId': socket.id, 'connectTime': Date.now()});
        
        socket.on('client connect', function(data) {
            observer.onNext({'socket': socket, 'data': data, 'event': 'client connect'});       
        });                
    });    
});

var observerConnect = sourceConnect
.subscribe(function(obj) {
    var socketId = obj.data.socketId;
    usersMap = usersMap.set(socketId, obj.data);
    io.emit('all users', usersMap.toArray());
});