packages/ddp-server/stream_server.js
function (callback) {
    var self = this;
    self.registration_callbacks.push(callback);
    _.each(self.all_sockets(), function (socket) {
      callback(socket);
    });
  }
function (callback) {
    var self = this;
    self.registration_callbacks.push(callback);
    _.each(self.all_sockets(), function (socket) {
      callback(socket);
    });
  }
function ( callback ) { var self = this ; self . registration_callbacks . push ( callback ) ; _ . each ( self . all_sockets ( ) , function ( socket ) { callback ( socket ) ; } ) ; }
call my callback when a new socket connects. also call it for all current connections.
call my callback when a new socket connects . also call it for all current connections .