docs: function _handleConnection(client) {
  	client.on('message', curry(_handleMessage, client))
  	client.on('disconnect', curry(_handleDisconnect, client))
  	client.pubsub = _engine.getPubSub()
  	_emitter.emit('client_connect', client)
  }