* Sends data to remote * * @param {Uint8Array} data data to be sent *
(data)
| 137 | * |
| 138 | */ |
| 139 | send(data) { |
| 140 | let reqHeader = new header.Header(header.STREAM), |
| 141 | stHeader = new header.InitialStream(0, 0), |
| 142 | d = new Uint8Array(data.length + 3); |
| 143 | |
| 144 | reqHeader.set(this.id); |
| 145 | stHeader.set(this.command, data.length, true); |
| 146 | |
| 147 | d[0] = reqHeader.value(); |
| 148 | d.set(stHeader.buffer(), 1); |
| 149 | d.set(data, 3); |
| 150 | |
| 151 | return this.sender.send(d); |
| 152 | } |
| 153 | } |
| 154 | |
| 155 | export class Stream { |