123456789101112131415161718192021222324252627282930313233343536373839404142 |
- 'use strict';
-
- var Message = function() {
- this.rsv1 = false;
- this.rsv2 = false;
- this.rsv3 = false;
- this.opcode = null
- this.length = 0;
- this._chunks = [];
- };
-
- var instance = {
- read: function() {
- if (this.data) return this.data;
-
- this.data = new Buffer(this.length);
- var offset = 0;
-
- for (var i = 0, n = this._chunks.length; i < n; i++) {
- this._chunks[i].copy(this.data, offset);
- offset += this._chunks[i].length;
- }
- return this.data;
- },
-
- pushFrame: function(frame) {
- this.rsv1 = this.rsv1 || frame.rsv1;
- this.rsv2 = this.rsv2 || frame.rsv2;
- this.rsv3 = this.rsv3 || frame.rsv3;
-
- if (this.opcode === null) this.opcode = frame.opcode;
-
- this._chunks.push(frame.payload);
- this.length += frame.length;
- }
- };
-
- for (var key in instance)
- Message.prototype[key] = instance[key];
-
- module.exports = Message;
|