Blame view

node_modules/websocket-driver/lib/websocket/driver/hybi/message.js 888 Bytes
aaac7fed   liuqimichale   add
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
  '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;