minor update
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8cb5aef9 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8cb5aef9 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8cb5aef9 Branch: refs/heads/ignite-7777 Commit: 8cb5aef96189c88d58a4f199857b05981c192687 Parents: 8d88012 Author: ekaterina-nbl <[email protected]> Authored: Mon May 14 13:09:35 2018 +0300 Committer: ekaterina-nbl <[email protected]> Committed: Mon May 14 13:09:35 2018 +0300 ---------------------------------------------------------------------- modules/platforms/nodejs/lib/internal/ClientSocket.js | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/8cb5aef9/modules/platforms/nodejs/lib/internal/ClientSocket.js ---------------------------------------------------------------------- diff --git a/modules/platforms/nodejs/lib/internal/ClientSocket.js b/modules/platforms/nodejs/lib/internal/ClientSocket.js index e32ef21..0f031a9 100644 --- a/modules/platforms/nodejs/lib/internal/ClientSocket.js +++ b/modules/platforms/nodejs/lib/internal/ClientSocket.js @@ -183,10 +183,7 @@ class ClientSocket { try { const message = await request.getMessage(); this._logMessage(request.id.toString(), true, message); - - if (!this._socket.write(message)) { - throw Errors.IgniteClientError.internalError('Request sending failed'); - } + this._socket.write(message); } catch (err) { this._requests.delete(request.id);
