fix(esSynchronise): using end event on stream, cause close may be emitted earlier than all docs will be passed to Bulker

Author: nodkz

lib/index.js

@@ -396,7 +396,7 @@ function synchronize(conditions, projection, options, callback) {
       }
     });
 
-    stream.on('close', () => {
+    stream.on('end', () => {
       streamClosed = true;
       if (bulker.filled()) {
         bulker.flush();