Nodejs stream (Ошибка: не удается установить заголовки после их отправки)

Question

Я пытаюсь создать api из серверов braintree. Ссылаясь на этот документ https://developers.braintreepayments.com/javascript+node/reference/general/result-handling/search-results

Чтобы получить доступ ко всем транзакциям со своего сервера, я должен вернуть поток узлов.

экс

app.get('/project', function(req, res) { 
    if(req.user) { 

     var stream = gateway.transaction.search(function (search) { 
     search.customerId().is(req.user.id); 
     }); 

     stream.on("ready", function() { 
     console.log(stream.searchResponse); 
     }); 

     stream.on("data", function (data) { 
     res.json(data) // can't set headers after they are sent. 
     }); 

    } 
}); 

Я понимаю возвращает поток данных в куски, так что выше res.json(), скорее всего, вызывается несколько раз приводит к Error: Can't set headers after they are sent.

Итак, мой вопрос в том, как я могу отправить эти данные клиенту в один кусок? Потоки nodejs меня сбивают с толку, я собираюсь больше узнать об этом, но было бы прекрасно понять, как отправить данные клиенту без повторной отправки заголовков.

Answer 1

Вы не должны делать никаких предположений о событиях data, если поток, который вы читаете, находится в режиме объекта. Вы можете получить одно событие data или сотню (в зависимости от размера ввода, конечно), потому что TCP - это поток.

То, что вы, вероятно, хотите что-то вроде этого вместо (предполагается, что stream не в режиме объекта):

app.get('/project', function(req, res) { 
    if(req.user) { 

     var stream = gateway.transaction.search(function (search) { 
     search.customerId().is(req.user.id); 
     }); 

     stream.on("ready", function() { 
     console.log(stream.searchResponse); 
     }); 

     var buf = ''; 
     stream.on("data", function (data) { 
     buf += data; 
     }); 

     stream.on("end", function() { 
     res.setHeader('Content-Type', 'application/json'); 
     res.send(buf); 
     }); 

    } 
}); 

Или просто труба поток в ответ:

app.get('/project', function(req, res) { 
    if(req.user) { 

     var stream = gateway.transaction.search(function (search) { 
     search.customerId().is(req.user.id); 
     }); 

     stream.on("ready", function() { 
     console.log(stream.searchResponse); 
     }); 

     res.setHeader('Content-Type', 'application/json'); 

     stream.pipe(res); 
    } 
}); 

Для потока объекта вы можете сделать:

app.get('/project', function(req, res) { 
    if(req.user) { 

     var stream = gateway.transaction.search(function (search) { 
     search.customerId().is(req.user.id); 
     }); 

     stream.on("ready", function() { 
     console.log(stream.searchResponse); 
     }); 

     var result = []; 
     stream.on("data", function (data) { 
     result.push(data); 
     }); 

     stream.on("end", function() { 
     res.json(result); 
     }); 

    } 
});