diff --git a/lib/native/index.js b/lib/native/index.js index 22f1885b..f0bbbef0 100644 --- a/lib/native/index.js +++ b/lib/native/index.js @@ -194,9 +194,13 @@ var clientBuilder = function(config) { } }); connection.on('_copyInResponse', function () { + //connection is ready to accept chunks + //start to send data from stream connection._activeQuery.streamData(connection); }); connection.on('_copyData', function (chunk) { + //recieve chunk from connection + //move it to stream connection._activeQuery.handleCopyFromChunk(chunk); }); return connection;