Maybe

test.js

var users = [];

users = socket.Observable
  .on('connect')
  .map(function (socket) {
    return socket;
  })
  .until(function () {
    return users.length != 10;
  });
  
console.log(users);