Method _onData

src/lsp/client.js:187–205

(data)

  }

  _onData(data) {
    this.buffer += data;
    const { messages, remaining } = decodeMessages(this.buffer);
    this.buffer = remaining;

    for (const msg of messages) {
      // Response to a request
      if (msg.id && this.pending.has(msg.id)) {
        const { resolve, reject } = this.pending.get(msg.id);
        this.pending.delete(msg.id);
        if (msg.error) reject(msg.error);
        else resolve(msg.result);
      }
      // Notification (diagnostics)
      if (msg.method === 'textDocument/publishDiagnostics') {
        this.diagnostics.set(msg.params.uri, msg.params.diagnostics || []);
      }
    }
  }
}

module.exports = { LSPClient, detectServer };