下面是我的代码，它在5次迭代后退出。我不明白为什么它只跑了5次，然后就退出了。我的表中有更多的数据。

function AddDataSync() {
        var query=connection.query('select officename, divisionname from table').
        stream()
        .pipe(stream.Transform({
    objectMode: true,
    transform: function(data,encoding,callback) {
      // do something with data...
        connection.pause();
        googleMapsClient.geocode({
               address: data.officename+' '+data.divisionname
                }, function(err, response) {
          if (!err) {
            console.log(response.json.results[0].geometry.location);
            connection.resume();
            callback();
          }
          else {
            console.log(err);
            connection.resume();
          }
        });
    }
   })).on('finish',function() { console.log('done');});
}