lib/dataprovider.js
function subscribe(message) {
		reply(proto.writeSubscribe(message.id));
		subscritions[message.itemName] = message.id;
		if (!isSnapshotAvailable(message.itemName)) {
			notify(proto.writeEndOfSnapshot(message.id, message.itemName));
		}
		dequeueSubUnsubRequest(message.itemName);
		fireFirstSubUnsubEvent(message.itemName);
	}
function subscribe(message) {
		reply(proto.writeSubscribe(message.id));
		subscritions[message.itemName] = message.id;
		if (!isSnapshotAvailable(message.itemName)) {
			notify(proto.writeEndOfSnapshot(message.id, message.itemName));
		}
		dequeueSubUnsubRequest(message.itemName);
		fireFirstSubUnsubEvent(message.itemName);
	}
function subscribe ( message ) { reply ( proto . writeSubscribe ( message . id ) ) ; subscritions [ message . itemName ] = message . id ; if ( ! isSnapshotAvailable ( message . itemName ) ) { notify ( proto . writeEndOfSnapshot ( message . id , message . itemName ) ) ; } dequeueSubUnsubRequest ( message . itemName ) ; fireFirstSubUnsubEvent ( message . itemName ) ; }
Sends a subscribe reply

@param {Object} message the decoded request message
@private
Sends a subscribe reply