
/**
 * Module dependencies.
 */

var Queue = require('./queue');

/**
 * Expose `PullSocket`.
 */

module.exports = PullSocket;

/**
 * Initialize a new `PullSocket`.
 *
 * @api private
 */

function PullSocket() {
  Queue.call(this);
  // TODO: selective reception
}

/**
 * Pull sockets should not send messages.
 */

PullSocket.prototype.send = function(){
  throw new Error('pull sockets should not send messages');
};

/**
 * Inherits from `Queue.prototype`.
 */

PullSocket.prototype.__proto__ = Queue.prototype;


/**
 * Module dependencies.
 */

var Socket = require('./sock');

/**
 * Expose `PullSocket`.
 */

module.exports = PullSocket;

/**
 * Initialize a new `PullSocket`.
 *
 * @api private
 */

function PullSocket() {
  Socket.call(this);
  // TODO: selective reception
}

/**
 * Inherits from `Socket.prototype`.
 */

PullSocket.prototype.__proto__ = Socket.prototype;

/**
 * Pull sockets should not send messages.
 */

PullSocket.prototype.send = function(){
  throw new Error('pull sockets should not send messages');
};

Remove queue socket proto