Microsoft/vscode
1
0
Fork 0
mirror of https://github.com/microsoft/vscode.git synced 2026-04-24 10:38:59 +01:00
Code Issues Packages Projects Releases Wiki Activity

Remove some unused functions in reader

Browse Source
This commit is contained in:
Matt Bierner
2017-05-18 15:37:50 -07:00
parent 2dfdd52a09
commit 7d2739bfe4
1 changed files with 10 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

67
extensions/typescript/src/utils/wireProtocol.ts
View File

@@ -7,12 +7,12 @@
import stream = require('stream');
let DefaultSize: number = 8192;
let ContentLength: string = 'Content-Length: ';
let ContentLengthSize: number = Buffer.byteLength(ContentLength, 'utf8');
let Blank: number = new Buffer(' ', 'utf8')[0];
let BackslashR: number = new Buffer('\r', 'utf8')[0];
let BackslashN: number = new Buffer('\n', 'utf8')[0];
const DefaultSize: number = 8192;
const ContentLength: string = 'Content-Length: ';
const ContentLengthSize: number = Buffer.byteLength(ContentLength, 'utf8');
const Blank: number = new Buffer(' ', 'utf8')[0];
const BackslashR: number = new Buffer('\r', 'utf8')[0];
const BackslashN: number = new Buffer('\n', 'utf8')[0];
class ProtocolBuffer {
@@ -83,36 +83,6 @@ class ProtocolBuffer {
this.index = this.index - sourceStart;
return result;
}
public tryReadLine(): string | null {
let end: number = 0;
while (end < this.index && this.buffer[end] !== BackslashR && this.buffer[end] !== BackslashN) {
end++;
}
if (end >= this.index) {
return null;
}
let result = this.buffer.toString('utf8', 0, end);
while (end < this.index && (this.buffer[end] === BackslashR || this.buffer[end] === BackslashN)) {
end++;
}
if (this.index === end) {
this.index = 0;
} else {
this.buffer.copy(this.buffer, 0, end);
this.index = this.index - end;
}
return result;
}
public get numberOfBytes(): number {
return this.index;
}
}
export enum ReaderType {
Length = 0,
Line = 1
}
export interface ICallback<T> {
@@ -126,20 +96,14 @@ export class Reader<T> {
private buffer: ProtocolBuffer;
private nextMessageLength: number;
public constructor(readable: stream.Readable, callback: ICallback<T>, type: ReaderType = ReaderType.Length) {
public constructor(readable: stream.Readable, callback: ICallback<T>) {
this.readable = readable;
this.buffer = new ProtocolBuffer();
this.callback = callback;
this.nextMessageLength = -1;
if (type === ReaderType.Length) {
this.readable.on('data', (data: Buffer) => {
this.onLengthData(data);
});
} else if (type === ReaderType.Line) {
this.readable.on('data', (data: Buffer) => {
this.onLineData(data);
});
}
this.readable.on('data', (data: Buffer) => {
this.onLengthData(data);
});
}
private onLengthData(data: Buffer): void {
@@ -160,15 +124,4 @@ export class Reader<T> {
this.callback(json);
}
}
private onLineData(data: Buffer): void {
this.buffer.append(data);
while (true) {
let msg = this.buffer.tryReadLine();
if (msg === null) {
return;
}
this.callback(JSON.parse(msg));
}
}
}