ヘッダーがKoaで送信された後にヘッダーを削除できません

Question

RESTサービスを管理するための最小限のサーバーをコーディングしました。コード化された唯一のルートは、mongoからデータを取り出し、それをクライアントに送信することになっています。コードは以下のとおりです。私はそれに到達しようとすると

var kr = require('koa-route'); 
var koa = require('koa'); 
var app = koa(); 

var MongoClient = require("mongodb").MongoClient; 

var events = function *() 
{ 
    var _this = this; 

    MongoClient.connect("mongodb://localhost/eventdata", function(error, db) { 
     if (error) throw(error); 
     console.log("Connecté à la base de données"); 

     db.collection('events').find().toArray(function(err, array) 
     { 
      console.log('returning %d objects', array.length); 
      db.close(); 
      _this.body = {eventsArray : array}; 

     }); 
    }); 
} 

app.use(kr.get('/events', events)); 

app.listen(3000); 

興亜は、バージョン1.2.4

ですが、私はエラーメッセージが「それらが送られた後、ヘッダを削除することはできません」を取得します。 find（）の前に応答を返すようにプログラム（sort of）が終了したことを理解しました。したがって、_this.body = {...}が呼び出されると、エラーが発生します。

今問題を解決するにはどうすればよいですか？ 私はちょうどKoaを練習し始めたので、慣れていないものがたくさんあります。

私がここで提案したソリューションをテストしました：Can't remove headers after they are sentしかし、動作しません。あなたの助けを事前に

eventsArray = yield db.collection('events').find({}) 
        ^^ 
SyntaxError : unexpected identifier 

ありがとう：私は、次のエラーメッセージが表示されます。

Answer 1

あなたが約束するためにdb reqをラップする必要があるようです。

var kr = require('koa-route'); 
 
var koa = require('koa'); 
 
var app = koa(); 
 

 
var MongoClient = require("mongodb").MongoClient; 
 
var eventsPromise = function(){ 
 
    return new Promise(function(resolve, reject){ 
 
     MongoClient.connect("mongodb://localhost/eventdata", function(error, db) { 
 
     if (error){ 
 
      return reject(error); 
 
     } 
 
     console.log("Connecté à la base de données"); 
 

 
     db.collection('events').find().toArray(function(err, array) 
 
     { 
 
      console.log('returning %d objects', array.length); 
 
      db.close(); 
 
      return reslove({eventsArray : array}); 
 
     }); 
 
    }); 
 
    }); 
 
} 
 
var events = function *() 
 
{ 
 
    var event = yiled eventsPromise(); 
 
    this.body = event; 
 
} 
 

 
app.use(kr.get('/events', events)); 
 

 
app.listen(3000);