Whenfinished Promise about node-datapumps HOT 5 CLOSED

var config = {
    user: source_database_server_user,
    password: source_database_server_password,
    server: source_server, // You can use 'localhost\\instance' to connect to named instance
    database: source_database,
    //stream: true, // You can enable streaming globally
    requestTimeout: source_server_database_query_timeout,
    options: {
        encrypt: true // Use this if you're on Windows Azure
    }
}

var connection = new mssql.Connection(config, function (err) {
    // ... error checks
    if (err) {
        console.log(err);
        return;
    }
    var request = connection.request();
    request.stream = true;
    //Parameter
    //request.input('locationid', mssql.Int, 6);
    var sql_query = source_sql_query;

    request.query(sql_query,
        function (err, recordSet) {
            // ... error checks
            if (err) {
                console.log(err);
                return;
            }
        });

    request.on('row', function(row) {
        data_pump.from().writeAsync(row);

    });

});
// Setup the data pump
var data_pump = new datapumps.Pump().from(new datapumps.Buffer());

//Process the Post operation
data_pump
    .mixin(datapumps.mixin.RestMixin)
    .process(function (data) {
        var record = '<some json looking data';

            return this.post(target_service_end_point, {

            multipart: false,

            headers: {
                'Content-Type' : 'application/json',

                'X-ApiKey' : 
 target_service_end_point_shared_secret
            },

            data: record
        }).then(function(response) {

            console.log(data.Email + '*******************************************');
            console.log(response.result);
            return this.copy(response);
        }.bind(this));

    }).logErrorsToConsole().start()
    .whenFinished().then(function(data){
     console.log("The processing is finished");    
     console.log(data);
});